Skip to content

Commit

Permalink
undo changes
Browse files Browse the repository at this point in the history
  • Loading branch information
jackgerrits committed Jan 11, 2025
1 parent ffcddb2 commit 79de944
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -406,7 +406,6 @@ async def stop_runtime() -> None:
recipient=AgentId(type=self._group_chat_manager_topic_type, key=self._team_id),
cancellation_token=cancellation_token,
)

# Collect the output messages in order.
output_messages: List[AgentEvent | ChatMessage] = []
# Yield the messsages until the queue is empty.
Expand All @@ -426,8 +425,7 @@ async def stop_runtime() -> None:

finally:
# Wait for the shutdown task to finish.
if shutdown_task is not None:
await shutdown_task
await shutdown_task

# Clear the output message queue.
while not self._output_message_queue.empty():
Expand Down

0 comments on commit 79de944

Please sign in to comment.