dag dashboard

Author: elecvoid243

astrbot/core/astr_agent_tool_exec.py

@@ -414,9 +414,7 @@ async def _execute_handoff(
             "subagent_system_prompt",
             agent_name=agent_name,
             prompt_length=len(subagent_system_prompt),
-            prompt=subagent_system_prompt
-            if subagent_system_prompt
-            else None,
+            prompt=subagent_system_prompt if subagent_system_prompt else None,
         )
 
         # 构建子代理的追加内容

astrbot/core/astr_main_agent.py

@@ -1047,7 +1047,7 @@ async def _apply_subagent_manager_tools(
         history_enabled = orch_cfg.get("history_enabled", True)
         shared_context_enabled = orch_cfg.get("shared_context_enabled", False)
         SubAgentManager.configure(
-            max_subagent_count=dynamic_cfg.get("max_dynamic_subagent_count", 3),
+            max_subagent_count=dynamic_cfg.get("max_subagent_count", 3),
             auto_cleanup_per_turn=dynamic_cfg.get("auto_cleanup_per_turn", True),
             shared_context_enabled=shared_context_enabled,
             shared_context_maxlen=orch_cfg.get("shared_context_maxlen", 300),
@@ -1059,6 +1059,7 @@ async def _apply_subagent_manager_tools(
             rule_prompt=dynamic_cfg.get("rule_prompt", ""),
             time_prompt_enabled=orch_cfg.get("time_prompt_enabled", True),
             timezone=cfg.get("timezone", None),
+            dag_enabled=orch_cfg.get("dag_enabled", False),
         )
 
         # Enable subagent history and shared context if configured

astrbot/core/config/default.py

@@ -205,7 +205,7 @@
         "agents": [],
         "dynamic_agents": {
             "enabled": False,
-            "max_dynamic_subagent_count": 3,
+            "max_subagent_count": 5,
             "auto_cleanup_per_turn": True,
             "rule_prompt": (
                 "# Behavior Rules\n"
@@ -234,7 +234,7 @@
         "shared_context_maxlen": 300,
         "subagent_history_maxlen": 300,
         "execution_timeout": 1200,
-        "dag_enabled": True,
+        "dag_enabled": False,
         "dag_max_nodes": 10,
         "dag_max_parallel": 5,
         "dag_max_inject_length": 4000,

astrbot/core/subagent_manager.py

@@ -103,6 +103,7 @@ class SubAgentManager:
         "astrbot_execute_shell",
         "astrbot_execute_python",
     }
+    _dag_enabled: bool = False  # 是否启用 DAG 编排
     _session_timeout_seconds = (
         1800  # 会话存活时间。若有会话的subagent闲置时间超过该值，自动清理
     )
@@ -130,14 +131,17 @@ class SubAgentManager:
 | Instruction | Input → Process → Output (step-by-step) |
 | Tools | **Minimum necessary only** |
 
-### 2. Delegate
+### 2. Manual Delegate
 - Sequential: `transfer_to_*(...)` — block until return
 - Parallel: `transfer_to_*(..., background_task=True)` → `wait_for_subagent(name, timeout=secs)`
 
-### 3. Collect & Cleanup
+### 3. Collect
 - Merge independent outputs by concatenation
 - Resolve conflicts by preferring explicit data over inference
 {_SUBAGENT_AUTOCLEAN_PROMPT}"""
+    _DAG_GUIDE_PROMPT = """## DAG Orchestration
+DAG Orchestration automatically delegate subagents. When you have 2+ independent tasks that can run in parallel, or tasks with clear dependencies, prefer to use `orchestrate_tasks` to declare them all at once.
+"""
 
     @classmethod
     def build_task_router_prompt(cls, session_id: str):
@@ -149,6 +153,9 @@ def build_task_router_prompt(cls, session_id: str):
             cls._HEADER_TEMPLATE,
             cls._CREATE_GUIDE_PROMPT,
         ]
+        if cls._dag_enabled:
+            parts.append(cls._DAG_GUIDE_PROMPT)
+
         return "\n".join(parts) + "\n"
 
     @classmethod
@@ -166,6 +173,7 @@ def configure(
         rule_prompt: str = "",
         time_prompt_enabled: bool = True,
         timezone: str | None = None,
+        dag_enabled: bool = False,
         **kwargs,
     ) -> None:
         """Configure SubAgentManager settings"""
@@ -179,6 +187,7 @@ def configure(
         cls._rule_prompt = rule_prompt
         cls._time_prompt_enabled = time_prompt_enabled
         cls._timezone = timezone
+        cls._dag_enabled = dag_enabled
         if tools_inherent is None:
             cls._tools_inherent = {
                 "astrbot_execute_shell",

astrbot/dashboard/routes/subagent.py

@@ -40,7 +40,7 @@ async def get_config(self):
                     "agents": [],
                     "dynamic_agents": {
                         "enabled": False,
-                        "max_dynamic_subagent_count": 3,
+                        "max_subagent_count": 3,
                         "auto_cleanup_per_turn": True,
                         "tools_blacklist": [],
                         "tools_inherent": [],
@@ -68,7 +68,7 @@ async def get_config(self):
             dyn = data["dynamic_agents"]
             if isinstance(dyn, dict):
                 dyn.setdefault("enabled", False)
-                dyn.setdefault("max_dynamic_subagent_count", 3)
+                dyn.setdefault("max_subagent_count", 3)
                 dyn.setdefault("auto_cleanup_per_turn", True)
                 dyn.setdefault("tools_blacklist", [])
                 dyn.setdefault("tools_inherent", [])

dashboard/src/i18n/locales/en-US/features/subagent.json

@@ -97,6 +97,16 @@
     "subtitle": "Add a new subagent to get started",
     "action": "Create First Agent"
   },
+  "dag": {
+    "orchestrationMode": "Orchestration Mode",
+    "orchestrationModeHint": "Choose the orchestration mode for subagent tasks. \"Default\" lets the LLM delegate tasks one by one manually; \"DAG Orchestration\" uses a directed acyclic graph (DAG) to manage task dependencies and parallel execution.",
+    "maxNodes": "DAG Max Task Nodes",
+    "maxNodesHint": "Maximum number of task nodes allowed in a single DAG orchestration",
+    "maxParallel": "DAG Max Parallel Per Layer",
+    "maxParallelHint": "Maximum parallel tasks per layer. If the layer has more nodes than the limit, they will be processed in batches",
+    "maxInjectLength": "DAG Predecessor Result Injection Length",
+    "maxInjectLengthHint": "Maximum character count when injecting predecessor task results into successor task context. Excess content will be truncated"
+  },
   "enhancedSwitches": {
     "enable": "Enable Dynamic Subagents",
     "enableHint": "Enable dynamic subagent creation and management. When enabled, the main LLM can dynamically create subagents at runtime using create_subagent tools. Can coexist with static subagent orchestration.",

dashboard/src/i18n/locales/ru-RU/features/subagent.json

@@ -96,6 +96,16 @@
         "subtitle": "Добавьте первого под-агента, чтобы начать",
         "action": "Создать первого агента"
     },
+    "dag": {
+        "orchestrationMode": "Режим оркестрации",
+        "orchestrationModeHint": "Выберите режим оркестрации задач субагентов. «По умолчанию» — LLM делегирует задачи вручную одну за другой; «DAG-оркестрация» — использует направленный ациклический граф (DAG) для управления зависимостями и параллельным выполнением.",
+        "maxNodes": "DAG: макс. число узлов",
+        "maxNodesHint": "Максимальное количество узлов задач в одной DAG-оркестрации",
+        "maxParallel": "DAG: макс. параллельных на слой",
+        "maxParallelHint": "Максимальное количество параллельных задач на один слой. Если узлов в слое больше лимита, они обрабатываются пакетами",
+        "maxInjectLength": "DAG: длина вставки результатов предшественников",
+        "maxInjectLengthHint": "Максимальное количество символов при вставке результатов предшествующих задач в контекст последующей задачи. Избыточное содержимое обрезается"
+    },
     "enhancedSwitches": {
         "enable": "Включить динамических субагентов",
         "enableHint": "Включить динамическое создание и управление субагентами. При включении основной LLM может динамически создавать субагентов во время выполнения с помощью инструментов create_subagent. Может сосуществовать со статической оркестрацией субагентов.",

dashboard/src/i18n/locales/zh-CN/features/subagent.json

@@ -97,6 +97,16 @@
     "subtitle": "添加一个新的子代理以开始",
     "action": "创建第一个 Agent"
   },
+  "dag": {
+    "orchestrationMode": "编排方式",
+    "orchestrationModeHint": "选择子代理任务的编排模式。「默认」由LLM手动逐个委派；「DAG 编排」使用有向无环图进行管理。",
+    "maxNodes": "DAG 最大任务节点数",
+    "maxNodesHint": "单个 DAG 编排中允许的最大任务节点数量",
+    "maxParallel": "DAG 单层最大并行数",
+    "maxParallelHint": "每层节点的最大并行数，若节点数超出并行数，会分批处理",
+    "maxInjectLength": "DAG 前置结果注入长度",
+    "maxInjectLengthHint": "将前置任务结果注入到后继任务上下文时的最大字符数，超出部分截断"
+  },
   "enhancedSwitches": {
     "enable": "启用动态子代理",
     "enableHint": "启用动态子代理创建、管理和回收能力。开启后主Agent可在运行时通过create_subagent等工具动态创建子代理。与静态子代理编排可同时存在",