We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3429c21 commit f583804Copy full SHA for f583804
awswrangler/cloudwatch.py
@@ -431,10 +431,9 @@ def filter_log_events(
431
describe_log_streams_args["boto3_session"] = boto3_session
432
if log_stream_name_prefix:
433
describe_log_streams_args["log_stream_name_prefix"] = log_stream_name_prefix
434
- log_stream_names = describe_log_streams(
435
- log_group_name=log_group_name, log_stream_name_prefix=log_stream_name_prefix, boto3_session=boto3_session
436
- )["logStreamName"].tolist()
437
- assert log_stream_names is not None
+ log_streams = describe_log_streams(**describe_log_streams_args)
+ log_stream_names = log_streams["logStreamName"].tolist() if len(log_streams.index) else []
+
438
args: Dict[str, Any] = {
439
"log_group_name": log_group_name,
440
}
0 commit comments