Merge branch 'main' into feature-github-actions-update

Author: FooFindBar

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -12,7 +12,7 @@ body:
     id: version
     attributes:
       label: What version of eigent are you using?
-      placeholder: E.g., 0.0.51
+      placeholder: E.g., 0.0.52
     validations:
       required: true
 

backend/app/service/chat_service.py

@@ -213,7 +213,7 @@ async def step_solve(options: Chat, request: Request, task_lock: TaskLock):
                     workforce.stop()
         except Exception as e:
             logger.error(f"Error processing action {item.action}: {e}")
-            raise e
+            yield sse_json("error", {"message": str(e)})
             # Continue processing other items instead of breaking
 
 
@@ -239,6 +239,7 @@ def tree_sub_tasks(sub_tasks: list[Task], depth: int = 0):
         return []
     return (
         chain(sub_tasks)
+        .filter(lambda x: x.content != "")
         .map(
             lambda x: {
                 "id": x.id,

backend/app/service/task.py

@@ -281,9 +281,9 @@ def create_task_lock(id: str) -> TaskLock:
     task_locks[id] = TaskLock(id=id, queue=asyncio.Queue(), human_input={})
 
     # Start cleanup task if not running
-    global _cleanup_task
-    if _cleanup_task is None or _cleanup_task.done():
-        _cleanup_task = asyncio.create_task(_periodic_cleanup())
+    # global _cleanup_task
+    # if _cleanup_task is None or _cleanup_task.done():
+    #     _cleanup_task = asyncio.create_task(_periodic_cleanup())
 
     return task_locks[id]
 

backend/app/utils/agent.py

@@ -706,6 +706,7 @@ def search_agent(options: Chat):
         stealth=True,
         session_id=str(uuid.uuid4())[:8],
         default_start_url="about:blank",
+        cdp_url=f"http://localhost:{env('browser_port', '9222')}",
         enabled_tools=[
             "browser_click",
             "browser_type",

backend/app/utils/toolkit/hybrid_browser_toolkit.py

@@ -15,6 +15,7 @@
 from camel.toolkits.hybrid_browser_toolkit.ws_wrapper import \
     WebSocketBrowserWrapper as BaseWebSocketBrowserWrapper
 from app.component.command import bun, uv
+from app.component.environment import env
 from app.service.task import Agents
 from app.utils.listen.toolkit_listen import listen_toolkit
 from app.utils.toolkit.abstract_toolkit import AbstractToolkit
@@ -428,7 +429,7 @@ def clone_for_new_session(self,
             dom_content_loaded_timeout=self._dom_content_loaded_timeout,
             viewport_limit=self._viewport_limit,
             connect_over_cdp=self.config_loader.get_browser_config().connect_over_cdp,
-            cdp_url=self.config_loader.get_browser_config().cdp_url,
+            cdp_url=f"http://localhost:{env('browser_port', '9222')}",
         )
 
     @classmethod

backend/app/utils/workforce.py

@@ -82,6 +82,7 @@ def eigent_make_sub_tasks(self, task: Task):
 
         self.reset()
         self._task = task
+        self.set_channel(TaskChannel())
         self._state = WorkforceState.RUNNING
         task.state = TaskState.OPEN
         self._pending_tasks.append(task)
@@ -105,7 +106,6 @@ async def eigent_start(self, subtasks: list[Task]):
         """start the workforce"""
         logger.debug(f"start the workforce {subtasks=}")
         self._pending_tasks.extendleft(reversed(subtasks))
-        self.set_channel(TaskChannel())
         # Save initial snapshot
         self.save_snapshot("Initial task decomposition")
 

backend/pyproject.toml

@@ -5,7 +5,7 @@ description = "Add your description here"
 readme = "README.md"
 requires-python = "==3.10.16"
 dependencies = [
-    "camel-ai[eigent]>=0.2.75a5",
+    "camel-ai[eigent]>=0.2.75a6",
     "fastapi>=0.115.12",
     "fastapi-babel>=1.0.0",
     "uvicorn[standard]>=0.34.2",

backend/uv.lock

@@ -0,0 +1,41 @@
+Eigent is designed to be extensible. Beyond the pre-configured agents, you can significantly expand your workforce's capabilities by connecting to external tools via custom MCP Servers and creating specialized workers to use them.
+
+This guide will walk you through how to integrate a new tool and build a custom worker step-by-step.
+
+## Configuring a Custom MCP Server
+
+The Model Context Protocol (MCP) is the framework that allows Eigent to connect to external tools and services like GitHub, Notion, or any other API. By adding a custom MCP server, you are essentially teaching your workforce a new skill.
+
+- Step 1: Click the **Settings** gear icon → Select the **MCP and Tools** tab.
+- Step 2: Click the **+ Add MCP Server** button to open the configuration dialog.
+- Step 3: Provide the Server Configuration
+    - **Paste the JSON configuration** for the server. This JSON file acts as a manifest, telling Eigent what the tool is, what functions it has, and how to call them. You can typically find this configuration file in the documentation of the third-party tool you wish to integrate.
+    - **Add required credentials**. Many tools require authentication. For example, to connect to GitHub, you will need to generate a Personal Access Token from your GitHub account settings and paste it into the appropriate field.
+
+<aside>
+
+
+📌 **Note on Security**
+
+Always treat your API keys and access tokens like passwords. Eigent stores them securely, but you should ensure they are generated with the minimum required permissions for the tasks you want to perform.
+
+</aside>
+
+![add mcp servers.gif](/docs/images/add_mcp_servers.gif)
+
+## Creating and Equipping a Custom Worker
+
+Once you've configured a new MCP server, you need to create a worker that knows how to use it. A worker is your specialized agent, and you can equip it with any combination of tools.
+
+- Step 1: On the **Canvas**, click the **+ Add Worker** button located in the bottom toolbar.
+- Step 2: Enter a clear Worker **Name** (e.g., "GitHub Specialist") and provide an optional **Description** of its duties (e.g., "Manages pull requests and repository issues").
+- Step 3: Equip your Worker with the new tool (most important!)
+    - Click on the **Agent Tool** dropdown menu.
+    - Select the custom MCP server you just configured (e.g., Github MCP). You can also add any other tools you want this worker to have.
+    - Click **Save**.
+
+![add worker.gif](/docs/images/add_worker.gif)
+
+## What’s next?
+
+That's it! You have successfully extended your AI workforce. You can now assign tasks that leverage your new integration.

docs/core/workers.md

@@ -59,7 +59,8 @@
               "/core/concepts",
               "/core/workforce",
               "/core/models",
-              "/core/tools"
+              "/core/tools",
+              "workers"
             ]
           },
           {