Skip to content

Commit 1a87982

Browse files
committed
fixed potential issue
1 parent 14379a1 commit 1a87982

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

robusta_krr/core/integrations/kubernetes/__init__.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -318,16 +318,17 @@ async def _list_namespaced_or_global_objects_batched(
318318
for namespace in self.namespaces
319319
]
320320

321+
gathered_results = await asyncio.gather(*requests)
322+
321323
result = [
322324
item
323-
for request_result in await asyncio.gather(*requests)
325+
for request_result in gathered_results
324326
for item in request_result.items
325327
]
326328

327329
next_continue_ref = None
328-
if requests:
329-
first_result = await requests[0]
330-
next_continue_ref = getattr(first_result.metadata, '_continue', None)
330+
if gathered_results:
331+
next_continue_ref = getattr(gathered_results[0].metadata, '_continue', None)
331332

332333
return result, next_continue_ref
333334

0 commit comments

Comments
 (0)