Added exception for create_log_stream in test module

KhueNgocDang · KhueNgocDang · commit 8f8697204cc5 · 2022-11-20T17:09:15.000+07:00
diff --git a/tests/test_cloudwatch.py b/tests/test_cloudwatch.py
@@ -61,7 +61,10 @@ def test_describe_log_streams_and_filter_log_events(loggroup):
         "aws_sdk_pandas_log_stream_four",
     ]
     for log_stream in log_stream_names:
-        cloudwatch_log_client.create_log_stream(logGroupName=loggroup, logStreamName=log_stream)
+        try:
+            cloudwatch_log_client.create_log_stream(logGroupName=loggroup, logStreamName=log_stream)
+        except cloudwatch_log_client.Client.exceptions.ResourceAlreadyExistsException:
+            continue
     log_streams_df = wr.cloudwatch.describe_log_streams(
         log_group_name=loggroup, order_by="LastEventTime", descending=False
     )

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,10 @@ def test_describe_log_streams_and_filter_log_events(loggroup):`
`61`	`61`	`"aws_sdk_pandas_log_stream_four",`
`62`	`62`	`]`
`63`	`63`	`for log_stream in log_stream_names:`
`64`		`- cloudwatch_log_client.create_log_stream(logGroupName=loggroup, logStreamName=log_stream)`
	`64`	`+ try:`
	`65`	`+ cloudwatch_log_client.create_log_stream(logGroupName=loggroup, logStreamName=log_stream)`
	`66`	`+ except cloudwatch_log_client.Client.exceptions.ResourceAlreadyExistsException:`
	`67`	`+ continue`
`65`	`68`	`log_streams_df = wr.cloudwatch.describe_log_streams(`
`66`	`69`	`log_group_name=loggroup, order_by="LastEventTime", descending=False`
`67`	`70`	`)`