Skip to content

Commit a1196d8

Browse files
committed
Create just one instance of agent controller per agent actor
1 parent 2b8f4f7 commit a1196d8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

llmstack/apps/runner/agent_actor.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,9 @@ def __init__(
5959
bookkeeping_queue=bookkeeping_queue,
6060
)
6161

62+
self._agent_output_queue = asyncio.Queue()
63+
self._agent_controller = AgentController(self._agent_output_queue, self._controller_config)
64+
6265
def _add_error_from_tool_call(self, output_index, tool_name, tool_call_id, errors):
6366
error_message = "\n".join([error for error in errors])
6467
self._stitched_data = stitch_model_objects(
@@ -445,9 +448,6 @@ def reset(self):
445448
self._process_output_task.cancel()
446449
self._process_output_task = None
447450

448-
self._agent_output_queue = asyncio.Queue()
449-
self._agent_controller = AgentController(self._agent_output_queue, self._controller_config)
450-
451451
# If there is no running event loop, create one and run the task
452452
try:
453453
loop = asyncio.get_running_loop()

0 commit comments

Comments
 (0)