Skip to content

Commit

Permalink
undo stop change
Browse files Browse the repository at this point in the history
  • Loading branch information
jackgerrits committed Jan 11, 2025
1 parent e3a26cb commit ffcddb2
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,8 @@ async def stop_runtime() -> None:
await self._runtime.stop_when_idle()
await self._output_message_queue.put(None)

shutdown_task: asyncio.Task[None] | None = None
shutdown_task = asyncio.create_task(stop_runtime())

try:
# Run the team by sending the start message to the group chat manager.
# The group chat manager will start the group chat by relaying the message to the participants
Expand All @@ -406,9 +407,6 @@ async def stop_runtime() -> None:
cancellation_token=cancellation_token,
)

# After sending the start message, we create the shutdown task that will wait for the runtime to become idle.
shutdown_task = asyncio.create_task(stop_runtime())

# Collect the output messages in order.
output_messages: List[AgentEvent | ChatMessage] = []
# Yield the messsages until the queue is empty.
Expand Down

0 comments on commit ffcddb2

Please sign in to comment.