diff --git a/python/packages/autogen-core/src/autogen_core/application/_worker_runtime.py b/python/packages/autogen-core/src/autogen_core/application/_worker_runtime.py
index 38ee44e509..74efecfc8b 100644
--- a/python/packages/autogen-core/src/autogen_core/application/_worker_runtime.py
+++ b/python/packages/autogen-core/src/autogen_core/application/_worker_runtime.py
@@ -453,11 +453,11 @@ class WorkerAgentRuntime(AgentRuntime):
 
                 future = send_message(agent, message_context)
             responses.append(future)
-            # Wait for all responses.
-            try:
-                await asyncio.gather(*responses)
-            except BaseException as e:
-                logger.error("Error handling event", exc_info=e)
+        # Wait for all responses.
+        try:
+            await asyncio.gather(*responses)
+        except BaseException as e:
+            logger.error("Error handling event", exc_info=e)
 
     async def register(
         self,