vrr/eigent
2
0
Fork 0
mirror of https://github.com/eigent-ai/eigent.git synced 2026-05-25 06:27:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

inital_fix

Browse source
This commit is contained in:
puzhen 2026-02-21 21:15:14 +00:00
parent c2149c6266
commit 7dbe5ffc67
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
backend/app/utils/workforce.py
View file

@ -936,8 +936,8 @@ class Workforce(BaseWorkforce):
if hasattr(self, "_children") and self._children:
for child in self._children:
# Cleanup base worker agent
if hasattr(child, "worker_agent"):
agent = child.worker_agent
if hasattr(child, "worker"):
agent = child.worker
cb = getattr(agent, "_cdp_release_callback", None)
if callable(cb):
try:
@ -969,10 +969,14 @@ class Workforce(BaseWorkforce):
from app.agent.factory.browser import _cdp_pool_manager
task_ids: set[str] = set()
# Use workforce's own api_task_id as the primary source
if self.api_task_id:
task_ids.add(self.api_task_id)
# Also collect from child agents
if hasattr(self, "_children") and self._children:
for child in self._children:
if hasattr(child, "worker_agent"):
tid = getattr(child.worker_agent, "_cdp_task_id", None)
if hasattr(child, "worker"):
tid = getattr(child.worker, "_cdp_task_id", None)
if tid is not None:
task_ids.add(tid)
if hasattr(child, "agent_pool") and child.agent_pool: