From 2d5f002ccc482cb539794f2f7ffcd67773f0584d Mon Sep 17 00:00:00 2001
From: puzhen <1303385763@qq.com>
Date: Sun, 15 Feb 2026 23:39:48 +0000
Subject: [PATCH] update

---
 backend/app/agent/listen_chat_agent.py     |  4 +---
 backend/app/utils/listen/toolkit_listen.py |  8 ++++++--
 backend/app/utils/single_agent_worker.py   | 10 ++++++++--
 backend/app/utils/telemetry/__init__.py    |  1 -
 backend/app/utils/workforce.py             |  4 +---
 5 files changed, 16 insertions(+), 11 deletions(-)

diff --git a/backend/app/agent/listen_chat_agent.py b/backend/app/agent/listen_chat_agent.py
index 786d8a4d..c3b7da7c 100644
--- a/backend/app/agent/listen_chat_agent.py
+++ b/backend/app/agent/listen_chat_agent.py
@@ -737,9 +737,7 @@ class ListenChatAgent(ChatAgent):
 
         # Restore original CDP URL in parent toolkit
         if new_cdp_port is not None and hasattr(self, "_browser_toolkit"):
-            self._browser_toolkit.config_loader.get_browser_config().cdp_url = (
-                original_cdp_url
-            )
+            self._browser_toolkit.config_loader.get_browser_config().cdp_url = original_cdp_url
 
         new_agent = ListenChatAgent(
             api_task_id=self.api_task_id,
diff --git a/backend/app/utils/listen/toolkit_listen.py b/backend/app/utils/listen/toolkit_listen.py
index 8070c104..1c2c9bbc 100644
--- a/backend/app/utils/listen/toolkit_listen.py
+++ b/backend/app/utils/listen/toolkit_listen.py
@@ -171,7 +171,9 @@ def _log_deactivate(
     )
 
 
-def _filter_kwargs_for_callable(func: Callable[..., Any], kwargs: dict) -> dict:
+def _filter_kwargs_for_callable(
+    func: Callable[..., Any], kwargs: dict
+) -> dict:
     """Drop unexpected kwargs unless the callable accepts **kwargs."""
     if not kwargs:
         return kwargs
@@ -179,7 +181,9 @@ def _filter_kwargs_for_callable(func: Callable[..., Any], kwargs: dict) -> dict:
         sig = signature(func)
     except (TypeError, ValueError):
         return kwargs
-    if any(param.kind == param.VAR_KEYWORD for param in sig.parameters.values()):
+    if any(
+        param.kind == param.VAR_KEYWORD for param in sig.parameters.values()
+    ):
         return kwargs
     allowed = set(sig.parameters.keys())
     return {k: v for k, v in kwargs.items() if k in allowed}
diff --git a/backend/app/utils/single_agent_worker.py b/backend/app/utils/single_agent_worker.py
index 77fffc1b..6b7de2e4 100644
--- a/backend/app/utils/single_agent_worker.py
+++ b/backend/app/utils/single_agent_worker.py
@@ -87,8 +87,14 @@ class SingleAgentWorker(BaseSingleAgentWorker):
                 `TaskState.FAILED`.
         """
         # Log task details before getting agent (for clone tracking)
-        task_content_preview = task.content[:100] + "..." if len(task.content) > 100 else task.content
-        logger.info(f"[TASK REQUEST] Requesting agent for task_id={task.id}, content_preview='{task_content_preview}'")
+        task_content_preview = (
+            task.content[:100] + "..."
+            if len(task.content) > 100
+            else task.content
+        )
+        logger.info(
+            f"[TASK REQUEST] Requesting agent for task_id={task.id}, content_preview='{task_content_preview}'"
+        )
 
         # Get agent efficiently (from pool or by cloning)
         worker_agent = await self._get_worker_agent()
diff --git a/backend/app/utils/telemetry/__init__.py b/backend/app/utils/telemetry/__init__.py
index 3a4d90c0..fa7455a0 100644
--- a/backend/app/utils/telemetry/__init__.py
+++ b/backend/app/utils/telemetry/__init__.py
@@ -11,4 +11,3 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 # ========= Copyright 2025-2026 @ Eigent.ai All Rights Reserved. =========
-
diff --git a/backend/app/utils/workforce.py b/backend/app/utils/workforce.py
index d50c60c4..b4bf6764 100644
--- a/backend/app/utils/workforce.py
+++ b/backend/app/utils/workforce.py
@@ -952,9 +952,7 @@ class Workforce(BaseWorkforce):
                 # Cleanup agents in AgentPool
                 if hasattr(child, "agent_pool") and child.agent_pool:
                     pool = child.agent_pool
-                    for agent in list(
-                        getattr(pool, "_available_agents", [])
-                    ):
+                    for agent in list(getattr(pool, "_available_agents", [])):
                         cb = getattr(agent, "_cdp_release_callback", None)
                         if callable(cb):
                             try: