File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ if [[ "$kind" == "LykonEventSourceMapping" ]]; then
79
79
# Get the current stream value
80
80
stream=$( yq eval ' .spec.parameters.stream' " $temp_yaml_file " )
81
81
82
- # Modify the stream based on whether it's S3 or Kinesis
82
+ # Modify the stream based on whether it's S3, Kinesis, or a simple Kinesis stream name
83
83
if [[ " $stream " == s3:* ]]; then
84
84
# Extract bucket name from the stream and form the S3 ARN
85
85
bucket_name=$( echo " $stream " | cut -d' :' -f2)
@@ -91,8 +91,9 @@ if [[ "$kind" == "LykonEventSourceMapping" ]]; then
91
91
new_stream=" arn:aws:kinesis:279707217826:stream/$stream_name "
92
92
yq eval " .spec.parameters.stream = \" $new_stream \" " -i " $temp_yaml_file "
93
93
else
94
- echo " Error: Unsupported stream format: $stream "
95
- exit 1
94
+ # Treat any other value as a simple Kinesis stream name and form the Kinesis ARN
95
+ new_stream=" arn:aws:kinesis:279707217826:stream/$stream "
96
+ yq eval " .spec.parameters.stream = \" $new_stream \" " -i " $temp_yaml_file "
96
97
fi
97
98
fi
98
99
You can’t perform that action at this time.
0 commit comments