INNER CODE UNIT · Python

gathered_results

robusta-dev/krr · robusta_krr/core/integrations/kubernetes/__init__.py:323

            gathered_results = await asyncio.gather(*requests)

            result = [item for request_result in gathered_results for item in request_result.items]

            next_continue_ref = None
            if gathered_results:
                next_continue_ref = getattr(gathered_results[0].metadata, "_continue", None)

            return result, next_continue_ref

        except ApiException as e:
            if e.status == 410 and e.body:
                # Continue token expired
                import json

                try:
                    error_body = json.loads(e.body)
                    new_continue_token = error_body.get("metadata", {}).get("continue")

View source record →