Skip to content

Commit 96e6a03

Browse files
committed
fix(workforce): Fix awaiting dynamic worker start
1 parent 61fc0d4 commit 96e6a03

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

camel/societies/workforce/workforce.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3848,7 +3848,9 @@ async def _create_worker_node_for_task(self, task: Task) -> Worker:
38483848
role=new_node_conf.role,
38493849
metadata={'description': new_node_conf.description},
38503850
)
3851-
self._child_listening_tasks.append(await new_node.start())
3851+
self._child_listening_tasks.append(
3852+
asyncio.create_task(new_node.start())
3853+
)
38523854
return new_node
38533855

38543856
async def _create_new_agent(self, role: str, sys_msg: str) -> ChatAgent:

0 commit comments

Comments
 (0)