diff --git a/lib/crewai/src/crewai/a2a/utils/delegation.py b/lib/crewai/src/crewai/a2a/utils/delegation.py index adbc8786f..0fc9eaec5 100644 --- a/lib/crewai/src/crewai/a2a/utils/delegation.py +++ b/lib/crewai/src/crewai/a2a/utils/delegation.py @@ -168,7 +168,10 @@ def execute_a2a_delegation( ) ) finally: - loop.close() + try: + loop.run_until_complete(loop.shutdown_asyncgens()) + finally: + loop.close() async def aexecute_a2a_delegation(