Fix bug in process event in worker runtime (#492)

This commit is contained in:
Eric Zhu
2024-09-13 00:02:03 -07:00
committed by GitHub
parent 3ab51d3006
commit 1ba7a681a9

View File

@@ -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,