Skip to content

Commit 0f9e47c

Browse files
adding a fix for pagination of log groups (#678)
* adding a fix for pagination of log groups * removing redundant variable
1 parent 965dc0a commit 0f9e47c

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

src/SimpleReplay/helper/aws_service.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,14 @@ def cw_describe_log_groups(log_group_name=None, region=None):
6464
logGroupNamePrefix=log_group_name
6565
)
6666
else:
67-
return cloudwatch_client.describe_log_groups()
67+
logs = cloudwatch_client.describe_log_groups()
68+
69+
token = logs.get('nextToken','')
70+
while token != '':
71+
response_itr = cloudwatch_client.describe_log_groups(nextToken=token)
72+
logs['logGroups'].extend(response_itr['logGroups'])
73+
token = response_itr['nextToken'] if 'nextToken' in response_itr.keys() else ''
74+
return logs
6875

6976

7077
def cw_describe_log_streams(log_group_name, region):

0 commit comments

Comments
 (0)