feat(agent): crewai orchestrator (#608)

* Feat: new control interface for crew, added crew orchestrator node

* orchestrator wip

* feat(agent_crewai): expose expert config fields for both node types

Add goal, backstory, expected_output, max_iter to agent_crewai (CrewDriver)
and goal, backstory, max_iter to agent_crewai_orchestrator (OrchestratorDriver).
All fields fall back to existing defaults when blank/zero.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* chore: cleanup modified crew code

* Chore: Delete Crew readme

* chore: rename 'expert' mode to 'advanced' mode

* chore: remove dead code found by code rabbit

* Fix: Rename orchestrator to Manager; remove tool invoke from manager node

* fix: propagate sub-agent advanced config through crewai.describe()

goal, backstory, expected_output, and instructions were all loaded from
connConfig but not included in DescribeResponse, causing the manager to
silently fall back to hardcoded defaults for every sub-agent.

- Add goal, backstory, expected_output, instructions to DescribeResponse
- Populate them in CrewDriver.describe()
- Use d.goal/backstory/expected_output in ManagerDriver sub-agent build
- Append instructions to sub-agent backstory (substitutes for the
  run_agent() path that is bypassed in manager mode)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

---------

Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: 2 people

nodes/src/nodes/agent_crewai/IGlobal.py

@@ -26,12 +26,17 @@
 import os
 from typing import Any
 
-from rocketlib import IGlobalBase, OPEN_MODE
+from rocketlib import IGlobalBase, IJson, OPEN_MODE
 
 
 class IGlobal(IGlobalBase):
     process: Any = None
     agent: Any = None
+    role: str = 'Assistant'
+    task_description: str = ''
+    goal: str = ''
+    backstory: str = ''
+    expected_output: str = ''
 
     def beginGlobal(self) -> None:
         if self.IEndpoint.endpoint.openMode == OPEN_MODE.CONFIG:
@@ -46,10 +51,28 @@ def beginGlobal(self) -> None:
 
         self.process = Process.sequential
 
-        from .crewai import CrewDriver
+        conn_config = IJson.toDict(self.glb.connConfig) if self.glb.connConfig else {}
 
-        self.agent = CrewDriver(self, process=self.process)
+        self.goal = str(conn_config.get('goal') or '').strip()
+        self.backstory = str(conn_config.get('backstory') or '').strip()
+
+        if self.glb.logicalType == 'agent_crewai_manager':
+            from .crewai import ManagerDriver
+
+            self.agent = ManagerDriver(self)
+        else:
+            self.role = str(conn_config.get('role') or 'Assistant').strip() or 'Assistant'
+            self.task_description = str(conn_config.get('task_description') or '').strip()
+            self.expected_output = str(conn_config.get('expected_output') or '').strip()
+            from .crewai import CrewDriver
+
+            self.agent = CrewDriver(self, process=self.process, role=self.role, task_description=self.task_description, goal=self.goal, backstory=self.backstory, expected_output=self.expected_output)
 
     def endGlobal(self) -> None:
         self.agent = None
         self.process = None
+        self.role = 'Assistant'
+        self.task_description = ''
+        self.goal = ''
+        self.backstory = ''
+        self.expected_output = ''

nodes/src/nodes/agent_crewai/IInstance.py

@@ -42,8 +42,24 @@ def writeQuestions(self, question: Question):
         self.IGlobal.agent.run_agent(self, question, emit_answers_lane=True)
 
     def invoke(self, param: Any) -> Any:  # noqa: ANN401
-        # Only intercept tool.* control-plane operations; otherwise fall back.
         op = param.get('op') if isinstance(param, dict) else getattr(param, 'op', None)
+
+        # crewai.describe fan-out: only sub-agents (CrewDriver) respond — guarded by hasattr.
+        # ManagerDriver has no describe() so it silently falls through.
+        if isinstance(op, str) and op == 'crewai.describe' and hasattr(self.IGlobal.agent, 'describe'):
+            descriptor = self.IGlobal.agent.describe(self)
+            existing = getattr(param, 'agents', None)
+            if isinstance(existing, list):
+                existing.append(descriptor)
+                try:
+                    param.agents = existing
+                except Exception:
+                    pass
+                return param
+            return [descriptor]
+
+        # tool.* control-plane operations for agent-as-tool.
         if isinstance(op, str) and op.startswith('tool.'):
             return self.IGlobal.agent.handle_invoke(self, param)
+
         return super().invoke(param)