fix: 修复了get_tool调用缓存协程对象的bug

* feat: restructure skills, introduce tools, and enhance chat UI

- Split worker_individual.py into separate component files: base, ordinary, special, and skill individuals.
- Update skill download and resolution paths to absolute references matching viceroy capabilities, correcting tmp and docker access issues.
- Introduce `GET /api/v1/resource/tool` and dynamic File Tool for agents to read file content.
- Update frontend Resource view to display tools instead of resource stubs.
- Convert Dashboard to Chat view, splitting chat interface to support standard chat or workflow deployment by appending prompt prefixes.

Co-authored-by: zhaoxi826 <198742034+zhaoxi826@users.noreply.github.com>

* feat: restructure skills, introduce tools, and enhance chat UI

- Split worker_individual.py into separate component files: base, ordinary, special, and skill individuals.
- Update skill download and resolution paths to absolute references matching viceroy capabilities, correcting tmp and docker access issues.
- Introduce `GET /api/v1/resource/tool` and dynamic File Tool for agents to read file content.
- Update frontend Resource view to display tools instead of resource stubs.
- Convert Dashboard to Chat view, splitting chat interface to support standard chat or workflow deployment by appending prompt prefixes.

Co-authored-by: zhaoxi826 <198742034+zhaoxi826@users.noreply.github.com>

---------

Co-authored-by: google-labs-jules[bot] <161369871+google-labs-jules[bot]@users.noreply.github.com>
Co-authored-by: zhaoxi826 <198742034+zhaoxi826@users.noreply.github.com>

frontend/src/components/Agent/AgentLayout.tsx

@@ -21,7 +21,7 @@ export function AgentLayout({ agentTab, setAgentTab }: AgentLayoutProps) {
                className={`w-full flex items-center px-4 py-3 text-sm font-medium rounded-xl transition-all ${agentTab === 'worker' ? 'bg-blue-50 text-blue-600' : 'text-slate-600 hover:bg-slate-50 hover:text-slate-900'}`}
              >
                <Bot size={18} className="mr-3" />
-               Worker Individual
+               Individual
              </button>
              <button
                onClick={() => setAgentTab('providers')}

frontend/src/components/Agent/WorkerIndividualSettings.tsx

@@ -19,6 +19,7 @@ interface WorkerIndividual {
 export function WorkerIndividualSettings() {
   const [providers, setProviders] = useState<Provider[]>([]);
   const [workers, setWorkers] = useState<WorkerIndividual[]>([]);
+  const [systemNodes, setSystemNodes] = useState<any[]>([]);
   const [loading, setLoading] = useState(true);
   const [error, setError] = useState('');
 
@@ -31,12 +32,32 @@ export function WorkerIndividualSettings() {
   const fetchData = async () => {
     setLoading(true);
     try {
-      const [provRes, workRes] = await Promise.all([
+      const [provRes, workRes, sysRes] = await Promise.all([
         apiClient.get('/api/v1/provider/list'),
-        apiClient.get('/api/v1/agent/worker')
+        apiClient.get('/api/v1/agent/worker'),
+        apiClient.get('/api/v1/agent')
       ]);
       setProviders(Object.values(provRes.data.provider_list || {}));
       setWorkers(workRes.data.workers || []);
+
+      const sysNodesData = sysRes.data.system_nodes || [];
+      const defaultSysNodes = ['supervisory_node', 'consciousness_node', 'control_node'];
+
+      const providersList = Object.values(provRes.data.provider_list || {}) as Provider[];
+      const defaultProvider = providersList.length > 0 ? providersList[0].provider_title : '';
+
+      const formattedSysNodes = defaultSysNodes.map(nodeName => {
+        const found = sysNodesData.find((n: any) => n.node_name === nodeName);
+        return {
+          agent_id: nodeName,
+          agent_name: nodeName,
+          agent_type: 'System Node',
+          provider_title: found && found.provider_title ? found.provider_title : defaultProvider,
+          model_id: found && found.model_id ? found.model_id : '',
+          is_system: true
+        };
+      });
+      setSystemNodes(formattedSysNodes);
     } catch (err: any) {
       console.error(err);
       setError('Failed to load data');
@@ -64,7 +85,7 @@ export function WorkerIndividualSettings() {
   const handleAddNew = () => {
     setEditData({
       agent_name: '',
-      agent_type: 'OrdinaryIndividual',
+      agent_type: 'ordinary_individual',
       description: '',
       provider_title: providers.length > 0 ? providers[0].provider_title : '',
       model_id: '',
@@ -93,6 +114,14 @@ export function WorkerIndividualSettings() {
     e.preventDefault();
     setModalMessage('');
     try {
+      if ((editData as any).is_system) {
+        const payload = {
+          individual_name: editData.agent_name,
+          provider_title: editData.provider_title,
+          model_id: editData.model_id
+        };
+        await apiClient.post('/api/v1/agent', payload);
+      } else {
         const payload = {
           ...editData,
           output_template: JSON.parse(editData.output_template || '{}'),
@@ -105,6 +134,7 @@ export function WorkerIndividualSettings() {
         } else {
           await apiClient.put(`/api/v1/agent/worker/${editData.agent_id}`, payload);
         }
+      }
 
       setIsEditing(false);
       fetchData();
@@ -118,7 +148,7 @@ export function WorkerIndividualSettings() {
     <div className="max-w-5xl space-y-6 relative">
       <div className="mb-8 flex justify-between items-end">
         <div>
-          <h1 className="text-2xl font-bold text-slate-800">Worker Individuals</h1>
+          <h1 className="text-2xl font-bold text-slate-800">Individual</h1>
           <p className="text-slate-500 mt-1">Manage all system nodes and custom workers.</p>
         </div>
         <button
@@ -136,8 +166,8 @@ export function WorkerIndividualSettings() {
         <div className="p-0">
           {loading ? (
             <div className="p-6 text-slate-500">Loading...</div>
-          ) : workers.length === 0 ? (
+          ) : (workers.length === 0 && systemNodes.length === 0) ? (
-            <div className="p-6 text-slate-500">No workers found.</div>
+            <div className="p-6 text-slate-500">No individuals found.</div>
           ) : (
             <table className="w-full text-left border-collapse">
               <thead>
@@ -149,6 +179,22 @@ export function WorkerIndividualSettings() {
                 </tr>
               </thead>
               <tbody>
+                {systemNodes.map((w) => (
+                  <tr key={w.agent_id} className="border-b border-slate-100 bg-slate-50 hover:bg-slate-100 transition-colors">
+                    <td className="p-4 font-medium text-slate-800">{w.agent_name}</td>
+                    <td className="p-4 text-slate-600">
+                      <span className="px-2 py-1 bg-blue-100 text-blue-800 rounded text-xs">{w.agent_type}</span>
+                    </td>
+                    <td className="p-4 text-slate-600 text-sm">
+                      {w.provider_title} <span className="text-slate-400">/</span> {w.model_id}
+                    </td>
+                    <td className="p-4 text-right space-x-2">
+                      <button onClick={() => handleEdit(w)} className="p-2 text-indigo-600 hover:bg-indigo-50 rounded-lg transition-colors" title="Edit">
+                        <Edit2 size={16} />
+                      </button>
+                    </td>
+                  </tr>
+                ))}
                 {workers.map((w) => (
                   <tr key={w.agent_id} className="border-b border-slate-100 hover:bg-slate-50 transition-colors">
                     <td className="p-4 font-medium text-slate-800">{w.agent_name}</td>
@@ -179,7 +225,9 @@ export function WorkerIndividualSettings() {
         <div className="fixed inset-0 bg-black/50 z-50 flex items-center justify-center p-4">
           <div className="bg-white rounded-xl shadow-xl w-full max-w-2xl max-h-[90vh] overflow-y-auto">
             <div className="flex justify-between items-center p-6 border-b border-slate-100 sticky top-0 bg-white z-10">
-              <h2 className="text-xl font-bold text-slate-800">{isNew ? 'Create Worker' : 'Edit Worker'}</h2>
+              <h2 className="text-xl font-bold text-slate-800">
+                {(editData as any).is_system ? 'Edit System Node' : (isNew ? 'Create Worker' : 'Edit Worker')}
+              </h2>
               <button onClick={() => setIsEditing(false)} className="text-slate-400 hover:text-slate-600">
                 <X size={24} />
               </button>
@@ -195,21 +243,23 @@ export function WorkerIndividualSettings() {
                     value={editData.agent_name || ''}
                     onChange={(e) => setEditData({...editData, agent_name: e.target.value})}
                     className="w-full px-4 py-2 border border-slate-200 rounded-lg focus:ring-2 focus:ring-indigo-500"
+                    disabled={(editData as any).is_system}
                   />
                 </div>
                 <div>
                   <label className="block text-sm font-medium text-slate-700 mb-1">Agent Type</label>
                   <select
-                    value={editData.agent_type || 'OrdinaryIndividual'}
+                    value={editData.agent_type || 'ordinary_individual'}
                     onChange={(e) => setEditData({...editData, agent_type: e.target.value})}
                     className="w-full px-4 py-2 border border-slate-200 rounded-lg focus:ring-2 focus:ring-indigo-500"
+                    disabled={(editData as any).is_system}
                   >
-                    <option value="supervisory_node">Supervisory Node</option>
+                    <option value="ordinary_individual">Ordinary Individual</option>
-                    <option value="consciousness_node">Consciousness Node</option>
+                    <option value="skill_individual">Skill Individual</option>
-                    <option value="control_node">Control Node</option>
+                    <option value="special_individual">Special Individual</option>
-                    <option value="OrdinaryIndividual">Ordinary Individual</option>
+                    {(editData as any).is_system && (
-                    <option value="SkillIndividual">Skill Individual</option>
+                      <option value="System Node">System Node</option>
-                    <option value="SpecialIndividual">Special Individual</option>
+                    )}
                   </select>
                 </div>
               </div>
@@ -249,6 +299,8 @@ export function WorkerIndividualSettings() {
                 </div>
               </div>
 
+              {!(editData as any).is_system && (
+                <>
                   <div>
                     <label className="block text-sm font-medium text-slate-700 mb-1">Description</label>
                     <textarea
@@ -299,6 +351,8 @@ export function WorkerIndividualSettings() {
                       className="w-full px-4 py-2 border border-slate-200 rounded-lg focus:ring-2 focus:ring-indigo-500 font-mono text-sm"
                     />
                   </div>
+                </>
+              )}
 
               {modalMessage && (
                 <div className="p-3 bg-red-50 text-red-700 text-sm rounded-lg">

frontend/src/components/Chat/ChatPanel.tsx

@@ -77,8 +77,9 @@ export function ChatPanel() {
 
     try {
       // Assuming a token might be needed, apiClient should handle it if set
+      const promptModifier = mode === 'deploy' ? '[DEPLOY TASK] ' : '';
       const response = await apiClient.post('/api/v1/adapter/client', {
-        message: userMessage.text
+        message: promptModifier + userMessage.text
       });
 
       const aiMessage: ChatMessage = {
@@ -113,12 +114,30 @@ export function ChatPanel() {
     }
   };
 
+  const [mode, setMode] = useState<'chat' | 'deploy'>('chat');
+
   return (
     <div className="flex-1 flex flex-col bg-slate-50">
-      <div className="h-14 border-b border-slate-200 bg-white flex items-center px-6 shadow-sm z-10">
+      <div className="h-14 border-b border-slate-200 bg-white flex items-center justify-between px-6 shadow-sm z-10">
+        <div className="flex items-center">
           <MessageSquare size={18} className="text-blue-600 mr-3" />
           <h1 className="font-semibold text-slate-800">Pretor Assistant</h1>
         </div>
+        <div className="flex space-x-2 bg-slate-100 p-1 rounded-lg">
+          <button
+            onClick={() => setMode('chat')}
+            className={`px-3 py-1 text-sm font-medium rounded-md transition-colors ${mode === 'chat' ? 'bg-white text-blue-600 shadow-sm' : 'text-slate-500 hover:text-slate-700'}`}
+          >
+            Chat
+          </button>
+          <button
+            onClick={() => setMode('deploy')}
+            className={`px-3 py-1 text-sm font-medium rounded-md transition-colors ${mode === 'deploy' ? 'bg-white text-blue-600 shadow-sm' : 'text-slate-500 hover:text-slate-700'}`}
+          >
+            Deploy Task
+          </button>
+        </div>
+      </div>
 
       {/* Chat History */}
       <div className="flex-1 p-6 overflow-y-auto space-y-6">

frontend/src/components/Layout/Sidebar.tsx

@@ -20,7 +20,7 @@ export function Sidebar({ currentView, setCurrentView }: SidebarProps) {
         <button
           onClick={() => setCurrentView('dashboard')}
           className={`p-1.5 rounded-lg transition-colors ${currentView === 'dashboard' ? 'text-blue-600 bg-blue-50' : 'text-slate-400 hover:text-blue-500 hover:bg-blue-50'}`}
-          title="Dashboard"
+          title="Chat"
         >
           <MessageSquare size={18} />
         </button>

frontend/src/components/Resource/ResourceLayout.tsx

@@ -1,6 +1,6 @@
 import { Wrench, Database, FileCode } from 'lucide-react';
 import { SkillSettings } from './SkillSettings';
-import { ResourceSettings } from './ResourceSettings';
+import { ToolSettings } from './ToolSettings';
 import { WorkflowTemplateSettings } from './WorkflowTemplateSettings';
 
 interface ResourceLayoutProps {
@@ -32,11 +32,11 @@ export function ResourceLayout({ resourceTab, setResourceTab }: ResourceLayoutPr
                Workflow Templates
              </button>
              <button
-               onClick={() => setResourceTab('resource')}
+               onClick={() => setResourceTab('tool')}
-               className={`w-full flex items-center px-4 py-3 text-sm font-medium rounded-xl transition-all ${resourceTab === 'resource' ? 'bg-blue-50 text-blue-600' : 'text-slate-600 hover:bg-slate-50 hover:text-slate-900'}`}
+               className={`w-full flex items-center px-4 py-3 text-sm font-medium rounded-xl transition-all ${resourceTab === 'tool' ? 'bg-blue-50 text-blue-600' : 'text-slate-600 hover:bg-slate-50 hover:text-slate-900'}`}
              >
                <Database size={18} className="mr-3" />
-               Resources
+               Tools
              </button>
           </div>
        </div>
@@ -45,7 +45,7 @@ export function ResourceLayout({ resourceTab, setResourceTab }: ResourceLayoutPr
        <div className="flex-1 overflow-y-auto p-8">
           {resourceTab === 'skill' && <SkillSettings />}
           {resourceTab === 'workflow_template' && <WorkflowTemplateSettings />}
-          {resourceTab === 'resource' && <ResourceSettings />}
+          {resourceTab === 'tool' && <ToolSettings />}
        </div>
     </div>
   );

frontend/src/components/Resource/ResourceSettings.tsx

@@ -1,13 +0,0 @@
-export function ResourceSettings() {
-  return (
-    <div className="max-w-4xl space-y-6">
-      <div className="mb-8">
-        <h1 className="text-2xl font-bold text-slate-800">Resource Management</h1>
-        <p className="text-slate-500 mt-1">Manage external and internal resources.</p>
-      </div>
-      <div className="bg-white rounded-xl shadow-sm border border-slate-200 overflow-hidden p-6 text-slate-500 text-sm">
-        Resource management configuration coming soon...
-      </div>
-    </div>
-  );
-}

frontend/src/components/Resource/ToolSettings.tsx

@@ -0,0 +1,64 @@
+import { useState, useEffect } from 'react';
+import { Package } from 'lucide-react';
+import apiClient from '../../api/client';
+
+export function ToolSettings() {
+  const [tools, setTools] = useState<string[]>([]);
+  const [loading, setLoading] = useState(true);
+
+  useEffect(() => {
+    fetchTools();
+  }, []);
+
+  const fetchTools = async () => {
+    try {
+      setLoading(true);
+      const response = await apiClient.get('/api/v1/resource/tool');
+      const toolsData = response.data.tools || [];
+      setTools(toolsData);
+    } catch (err) {
+      console.error('Failed to fetch tools:', err);
+    } finally {
+      setLoading(false);
+    }
+  };
+
+  return (
+    <div className="max-w-4xl space-y-6">
+      <div>
+        <h3 className="text-xl font-semibold text-slate-800">Installed Tools</h3>
+        <p className="text-slate-500 mt-1">Manage agent tools and functions.</p>
+      </div>
+
+      <div className="bg-white border border-slate-200 rounded-2xl shadow-sm overflow-hidden">
+        <div className="p-6 border-b border-slate-100 flex justify-between items-center bg-slate-50/50">
+          <div>
+            <h4 className="font-medium text-slate-800">Available Tools</h4>
+            <p className="text-sm text-slate-500">List of installed tools available for agents.</p>
+          </div>
+        </div>
+
+        <div className="p-6">
+          {loading ? (
+            <div className="text-slate-500 text-sm">Loading tools...</div>
+          ) : tools.length === 0 ? (
+            <div className="text-slate-500 text-sm">No tools installed yet.</div>
+          ) : (
+            <div className="grid grid-cols-1 md:grid-cols-2 gap-4">
+              {tools.map((tool) => (
+                <div key={tool} className="p-4 border border-slate-200 rounded-xl flex items-center justify-between hover:shadow-sm transition-shadow">
+                  <div className="flex items-center">
+                    <div className="w-10 h-10 bg-purple-50 rounded-lg flex items-center justify-center mr-3">
+                      <Package size={20} className="text-purple-600" />
+                    </div>
+                    <span className="font-medium text-slate-800">{tool}</span>
+                  </div>
+                </div>
+              ))}
+            </div>
+          )}
+        </div>
+      </div>
+    </div>
+  );
+}

pretor/api/agent.py

@@ -35,15 +35,31 @@ class AgentLocalRegister(BaseModel):
     path: str
     individual_name: str
 
+@agent_router.get("")
+async def get_system_nodes(_: TokenData = Depends(RoleChecker(allowed_roles=UserAuthority.USER))):
+    postgres_database = ray_actor_hook("postgres_database").postgres_database
+    configs = await postgres_database.get_all_system_node_configs.remote()
+    return {"system_nodes": configs}
+
 @agent_router.post("")
 async def load_agent(agent_register: Union[AgentRegister, AgentLocalRegister],
                      _: TokenData = Depends(RoleChecker(allowed_roles=UserAuthority.USER))):
     global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
+    postgres_database = ray_actor_hook("postgres_database").postgres_database
+
     if isinstance(agent_register, AgentLocalRegister):
         pass
 
     elif isinstance(agent_register, AgentRegister):
         try:
+            # Persist configuration
+            await postgres_database.upsert_system_node_config.remote(
+                agent_register.individual_name,
+                agent_register.provider_title,
+                agent_register.model_id
+            )
+
+            # Load agent into state machine
             match agent_register.individual_name:
                 case "supervisory_node":
                     node = ray_actor_hook("supervisory_node").supervisory_node

pretor/api/resource.py

@@ -53,9 +53,12 @@ async def install_skill(skill: Skill,
                         _: TokenData = Depends(RoleChecker(allowed_roles=UserAuthority.USER))):
     global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
     # noinspection PyUnresolvedReferences
+    import os
+    skill_output_dir = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "plugin", "skill"))
+    os.makedirs(skill_output_dir, exist_ok=True)
     await viceroy.install_skill_async(url = skill.repo_url,
                                 path = skill.path,
-                                output = "./pretor/plugin/tool_plugin")
+                                output = skill_output_dir)
     if skill.path:
         skill_name = skill.path.split("/")[-1]
     else:
@@ -75,3 +78,12 @@ async def delete_skill(skill_name: str, _: TokenData = Depends(RoleChecker(allow
     # Note: this only removes it from the state machine manager.
     await global_state_machine.remove_skill.remote( skill_name)
     return {"message": "success"}
+
+@resource_router.get("/tool")
+async def get_tools(_: TokenData = Depends(RoleChecker(allowed_roles=UserAuthority.USER))):
+    global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
+    tool_mapper = await global_state_machine.get_tool_mapper.remote()
+    all_tool_names = set()
+    for scope_tools in tool_mapper.values():
+        all_tool_names.update(scope_tools.keys())
+    return {"tools": list(all_tool_names)}

pretor/core/database/module/system_node.py

@@ -0,0 +1,52 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pretor.core.database.table.system_node import SystemNodeConfig
+from sqlmodel import select
+from typing import List, Optional
+from pretor.core.database.database_exception import database_exception
+
+class SystemNodeDatabase:
+    def __init__(self, async_session_maker):
+        self.async_session_maker = async_session_maker
+
+    @database_exception
+    async def upsert_system_node_config(self, node_name: str, provider_title: str, model_id: str) -> SystemNodeConfig:
+        async with self.async_session_maker() as session:
+            statement = select(SystemNodeConfig).where(SystemNodeConfig.node_name == node_name)
+            results = await session.execute(statement)
+            config = results.scalar_one_or_none()
+            if config:
+                config.provider_title = provider_title
+                config.model_id = model_id
+            else:
+                config = SystemNodeConfig(node_name=node_name, provider_title=provider_title, model_id=model_id)
+            session.add(config)
+            await session.commit()
+            await session.refresh(config)
+            return config
+
+    @database_exception
+    async def get_all_system_node_configs(self) -> List[SystemNodeConfig]:
+        async with self.async_session_maker() as session:
+            statement = select(SystemNodeConfig)
+            results = await session.execute(statement)
+            return list(results.scalars().all())
+
+    @database_exception
+    async def get_system_node_config(self, node_name: str) -> Optional[SystemNodeConfig]:
+        async with self.async_session_maker() as session:
+            statement = select(SystemNodeConfig).where(SystemNodeConfig.node_name == node_name)
+            results = await session.execute(statement)
+            return results.scalar_one_or_none()

pretor/core/database/postgres.py

@@ -23,6 +23,7 @@ from sqlmodel import SQLModel
 from pretor.core.database.module.individual import IndividualDatabase
 from pretor.core.database.module.user import AuthDatabase
 from pretor.core.database.module.provider import ProviderDatabase
+from pretor.core.database.module.system_node import SystemNodeDatabase
 
 @ray.remote
 class PostgresDatabase:
@@ -39,6 +40,7 @@ class PostgresDatabase:
         self._auth_database = AuthDatabase(self.async_session_maker)
         self._provider_database = ProviderDatabase(self.async_session_maker)
         self._individual_database = IndividualDatabase(self.async_session_maker)
+        self._system_node_database = SystemNodeDatabase(self.async_session_maker)
 
         self.ready_event = asyncio.Event()
 
@@ -103,6 +105,15 @@ class PostgresDatabase:
         await self.ready_event.wait()
         return await self._provider_database.update_provider(provider_id, **kwargs)
 
+    # System Node Database Methods
+    async def upsert_system_node_config(self, node_name: str, provider_title: str, model_id: str):
+        await self.ready_event.wait()
+        return await self._system_node_database.upsert_system_node_config(node_name, provider_title, model_id)
+
+    async def get_all_system_node_configs(self):
+        await self.ready_event.wait()
+        return await self._system_node_database.get_all_system_node_configs()
+
     # Individual Database Methods
     async def add_worker_individual(self, **kwargs):
         await self.ready_event.wait()

pretor/core/database/table/system_node.py

@@ -0,0 +1,21 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from sqlmodel import SQLModel, Field
+
+class SystemNodeConfig(SQLModel, table=True):
+    __tablename__ = "system_node_config"
+    node_name: str = Field(primary_key=True)
+    provider_title: str
+    model_id: str

pretor/core/global_state_machine/skill_manager.py

@@ -24,7 +24,8 @@ class GlobalSkillManager:
     def __init__(self):
         self.skill_mapper = defaultdict(tuple)
 
-        skill_plugin_dir = pathlib.Path(__file__).parent.parent.parent / "plugin" / "skill_plugin"
+        import os
+        skill_plugin_dir = pathlib.Path(os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..", "plugin", "skill")))
         if not skill_plugin_dir.exists() or not skill_plugin_dir.is_dir():
             return
         for item in skill_plugin_dir.iterdir():
@@ -46,7 +47,8 @@ class GlobalSkillManager:
 
     def add_skill(self, skill_name: str) -> None:
         """Add a skill to the manager by reading its skill.json from the path"""
-        skill_plugin_dir = pathlib.Path(__file__).parent.parent.parent / "plugin" / "skill_plugin"
+        import os
+        skill_plugin_dir = pathlib.Path(os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..", "plugin", "skill")))
         item = skill_plugin_dir / skill_name
         if item.is_dir() and not item.name.startswith((".", "__")):
             json_path = item / "skill.json"

pretor/core/individual/consciousness_node/consciousness_node.py

@@ -134,7 +134,7 @@ class ConsciousnessNode:
     async def _run(self, payload: Union[ForSupervisoryInput, ForWorkflowInput, ForWorkflowEngineInput]) -> Union[ForSupervisoryNode, ForWorkflow, ForWorkflowEngine]:
         try:
             self.agent.retries = 3
-            tool = get_tool("control_node")
+            tool = await get_tool("control_node")
             if isinstance(payload, ForWorkflowEngineInput):
                 deps = ConsciousnessNodeDeps(
                     original_command=payload.original_command,

pretor/core/individual/control_node/control_node.py

@@ -89,7 +89,7 @@ class ControlNode:
             )
             self.logger.debug(f"ControlNode: 开始执行工作流节点 [{payload.workflow_step.name}] (原生重试开启)")
 
-            tool = get_tool("control_node")
+            tool = await get_tool("control_node")
 
             result = await self.agent.run(
                 f"请根据提供的 workflow_step 上下文，执行此步骤并输出结果。\n详细指令或附加数据：{payload.workflow_step.model_dump_json()}",

pretor/core/individual/supervisory_node/supervisory_node.py

@@ -172,7 +172,7 @@ class SupervisoryNode:
             if isinstance(payload, TerminationMessage):
                 prompt_message = f"【工作流执行结束报告】\n请将以下技术报告转化为对用户的友好回复：\n{message}"
             self.agent.retries = 3
-            tool = get_tool("supervisory_node")
+            tool = await get_tool("supervisory_node")
             result = await self.agent.run(prompt_message,
                                           deps=deps,
                                           tools=tool)

pretor/plugin/tool_plugin/file_reader/__init__.py

@@ -0,0 +1,3 @@
+from .file_reader import FileReaderData, file_reader
+
+__all__ = ["FileReaderData", "file_reader"]

pretor/plugin/tool_plugin/file_reader/file_reader.py

@@ -0,0 +1,43 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pydantic_ai import RunContext
+from pretor.plugin.tool_plugin.base_tool import BaseToolData
+import os
+
+class FileReaderData(BaseToolData):
+    is_system: bool = True
+    name: str = "file_reader"
+    description: str = "读取本地文件的内容"
+
+def file_reader(ctx: RunContext, filepath: str) -> str:
+    """读取本地文件内容的工具。
+
+    Args:
+        filepath: 目标文件的绝对路径或相对路径。
+
+    Returns:
+        如果文件存在并可读，返回文件内容；否则返回错误信息。
+    """
+    if not os.path.exists(filepath):
+        return f"Error: 文件 {filepath} 不存在。"
+    if not os.path.isfile(filepath):
+        return f"Error: {filepath} 不是一个文件。"
+
+    try:
+        with open(filepath, 'r', encoding='utf-8') as f:
+            content = f.read()
+        return content
+    except Exception as e:
+        return f"Error: 读取文件失败，原因：{str(e)}"

pretor/utils/get_tool.py

@@ -15,12 +15,12 @@
 import importlib
 from typing import Callable, Dict, List
 import pathlib
-from functools import lru_cache
 from pretor.utils.ray_hook import ray_actor_hook
 
 from pretor.utils.logger import get_logger
 logger = get_logger('get_tool')
 _tool_cache: Dict[str, Callable] = {}
+_agent_tool_result_cache: Dict[str, List[Callable]] = {}
 
 
 def _get_tool_func(tool_name: str) -> Callable | None:
@@ -48,10 +48,13 @@ def del_tool_cache(tool_name: str) -> None:
         del _tool_cache[tool_name]
     refresh_agent_tools()
 
-@lru_cache(maxsize=1)
+
 async def get_tool(agent_name: str) -> List[Callable]:
+    cached = _agent_tool_result_cache.get(agent_name)
+    if cached is not None:
+        return cached
     global_state_machine = ray_actor_hook("global_state_machine")
-    _tool_list = await global_state_machine.get_tool_list.remote( agent_name)
+    _tool_list = await global_state_machine.get_tool_list.remote(agent_name)
     tool_list = []
     for tool_name in _tool_list.keys():
         tool_func = _get_tool_func(tool_name)
@@ -59,9 +62,8 @@ async def get_tool(agent_name: str) -> List[Callable]:
             tool_list.append(tool_func)
         else:
             continue
+    _agent_tool_result_cache[agent_name] = tool_list
     return tool_list
 
 def refresh_agent_tools() -> None:
-    get_tool.cache_clear()
+    _agent_tool_result_cache.clear()
-
-

pretor/worker_individual/__init__.py

@@ -0,0 +1,11 @@
+from pretor.worker_individual.base_individual import BaseIndividual
+from pretor.worker_individual.skill_individual import SkillIndividual
+from pretor.worker_individual.ordinary_individual import OrdinaryIndividual
+from pretor.worker_individual.special_individual import SpecialIndividual
+
+__all__ = [
+    "BaseIndividual",
+    "SkillIndividual",
+    "OrdinaryIndividual",
+    "SpecialIndividual",
+]

pretor/worker_individual/base_individual.py

@@ -0,0 +1,70 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pydantic_ai import Agent, RunContext
+from pydantic import Field
+from pretor.adapter.model_adapter.agent_factory import AgentFactory
+from pretor.core.global_state_machine.model_provider.base_provider import Provider
+from pretor.utils.agent_model import ResponseModel, InputModel, DepsModel
+from pretor.utils.ray_hook import ray_actor_hook
+
+from pretor.utils.logger import get_logger
+logger = get_logger('worker_individual')
+
+class WorkerIndividualResponse(ResponseModel):
+    output: str = Field(..., description="Worker执行任务的输出结果")
+
+class WorkerIndividualDeps(DepsModel):
+    task_event: dict
+
+class WorkerIndividualInput(InputModel):
+    task_event: dict
+
+class BaseIndividual:
+    """
+    Worker Individual 的基类
+    """
+
+    def __init__(self, agent_config: dict):
+        self.agent_config = agent_config
+        self.agent_id = agent_config.get("agent_id")
+        self.agent: Agent | None = None
+
+    async def _init_agent(self, agent_name: str, system_prompt: str):
+        global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
+        provider_title = self.agent_config.get("provider_title", "openai")  # default fallback
+        model_id = self.agent_config.get("model_id", "gpt-4o")  # default fallback
+
+        provider: Provider = await global_state_machine.get_provider.remote( provider_title)
+        agent_factory = AgentFactory()
+        self.agent = agent_factory.create_agent(
+            provider=provider,
+            model_id=model_id,
+            output_type=WorkerIndividualResponse,
+            system_prompt=system_prompt,
+            deps_type=WorkerIndividualDeps,
+            agent_name=agent_name
+        )
+
+        @self.agent.system_prompt
+        async def dynamic_prompt(ctx: RunContext[WorkerIndividualDeps]):
+            prompt = system_prompt + "\n\n"
+            prompt += (
+                f"=== 当前任务上下文 ===\n"
+                f"{ctx.deps.task_event}\n"
+            )
+            return prompt
+
+    async def run(self, task_event: dict) -> dict:
+        raise NotImplementedError("子类必须实现 run 方法")

pretor/worker_individual/ordinary_individual.py

@@ -0,0 +1,43 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pretor.worker_individual.base_individual import BaseIndividual, WorkerIndividualDeps
+from pretor.utils.logger import get_logger
+
+logger = get_logger('ordinary_individual')
+
+class OrdinaryIndividual(BaseIndividual):
+    """
+    普通子个体：普通的 agent。
+    """
+
+    def __init__(self, agent_config: dict):
+        super().__init__(agent_config)
+
+    async def run(self, task_event: dict) -> dict:
+        if self.agent is None:
+            system_prompt = self.agent_config.get("prompt", "你是一个普通的AI助手，请尽力完成给定的任务。")
+            await self._init_agent("ordinary_individual", system_prompt)
+
+        deps = WorkerIndividualDeps(task_event=task_event)
+        self.agent.retries = 3
+        try:
+            result = await self.agent.run(
+                f"请执行以下任务：\n{task_event}",
+                deps=deps
+            )
+            return {"output": result.data.output}
+        except Exception as e:
+            logger.exception(f"OrdinaryIndividual {self.agent_id} 执行失败: {e}")
+            raise

pretor/worker_individual/skill_individual.py

@@ -0,0 +1,110 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pretor.worker_individual.base_individual import BaseIndividual, WorkerIndividualDeps
+from pretor.utils.logger import get_logger
+import os
+import json
+from pydantic_ai import Tool
+import importlib.util
+
+logger = get_logger('skill_individual')
+
+class SkillIndividual(BaseIndividual):
+    """
+    专家子个体：拥有专业 skill 的 agent。
+    """
+
+    def __init__(self, agent_config: dict):
+        super().__init__(agent_config)
+
+    async def _load_skill_tools(self):
+        """动态加载已绑定的 skill 工具。"""
+        tools = []
+        bound_skill = self.agent_config.get("bound_skill", "")
+        # bound_skill can be string or dict {"skill_name": ["file1", "file2"]}
+        skill_mapper = {}
+        if isinstance(bound_skill, str) and bound_skill:
+            try:
+                skill_mapper = json.loads(bound_skill)
+            except json.JSONDecodeError:
+                pass
+        elif isinstance(bound_skill, dict):
+            skill_mapper = bound_skill
+
+        skill_base_dir = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "plugin", "skill"))
+
+        for skill_name, _ in skill_mapper.items():
+            skill_path = os.path.join(skill_base_dir, skill_name)
+            metadata_path = os.path.join(skill_path, "metadata.json")
+            if not os.path.exists(metadata_path):
+                continue
+
+            try:
+                with open(metadata_path, 'r', encoding='utf-8') as f:
+                    metadata = json.load(f)
+            except Exception as e:
+                logger.error(f"Failed to load metadata for skill {skill_name}: {e}")
+                continue
+
+            if "functions" in metadata:
+                for func_info in metadata["functions"]:
+                    # Ensure path is absolute
+                    script_path = func_info.get("file_path", "")
+                    if not os.path.isabs(script_path):
+                        script_path = os.path.join(skill_path, script_path)
+
+                    if not os.path.exists(script_path):
+                        logger.warning(f"Skill script not found: {script_path}")
+                        continue
+
+                    func_name = func_info.get("name")
+                    try:
+                        # Dynamically load the python module
+                        spec = importlib.util.spec_from_file_location(func_name, script_path)
+                        module = importlib.util.module_from_spec(spec)
+                        spec.loader.exec_module(module)
+
+                        func = getattr(module, func_name)
+                        if callable(func):
+                            # Convert to PydanticAI Tool
+                            tool = Tool(func, name=func_name, description=func_info.get("docstring", ""))
+                            tools.append(tool)
+                            logger.info(f"Loaded skill tool: {func_name} from {skill_name}")
+                    except Exception as e:
+                        logger.error(f"Failed to load function {func_name} from {script_path}: {e}")
+
+        return tools
+
+    async def run(self, task_event: dict) -> dict:
+        if self.agent is None:
+            system_prompt = self.agent_config.get("prompt",
+                                                  "你是一个拥有专业技能的专家级AI助手，请利用你的专业知识完成给定的任务。")
+            await self._init_agent("skill_individual", system_prompt)
+
+        deps = WorkerIndividualDeps(task_event=task_event)
+        self.agent.retries = 3
+
+        tools = await self._load_skill_tools()
+
+        try:
+            result = await self.agent.run(
+                f"请执行以下任务：\n{task_event}",
+                deps=deps,
+                tools=tools if tools else None
+            )
+            return {"output": result.data.output}
+        except Exception as e:
+            logger.exception(f"SkillIndividual {self.agent_id} 执行失败: {e}")
+            raise

pretor/worker_individual/special_individual.py

@@ -0,0 +1,43 @@
+#  Copyright 2026 zhaoxi826
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+from pretor.worker_individual.base_individual import BaseIndividual, WorkerIndividualDeps
+from pretor.utils.logger import get_logger
+
+logger = get_logger('special_individual')
+
+class SpecialIndividual(BaseIndividual):
+    """
+    特殊子个体：执行特殊任务的 agent，如生成语音、视频等。
+    """
+
+    def __init__(self, agent_config: dict):
+        super().__init__(agent_config)
+
+    async def run(self, task_event: dict) -> dict:
+        if self.agent is None:
+            system_prompt = self.agent_config.get("prompt", "你是一个特殊的AI助手，负责处理特殊类型的任务。")
+            await self._init_agent("special_individual", system_prompt)
+
+        deps = WorkerIndividualDeps(task_event=task_event)
+        self.agent.retries = 3
+        try:
+            result = await self.agent.run(
+                f"请执行以下任务：\n{task_event}",
+                deps=deps
+            )
+            return {"output": result.data.output}
+        except Exception as e:
+            logger.exception(f"SpecialIndividual {self.agent_id} 执行失败: {e}")
+            raise

pretor/worker_individual/worker_cluster.py

@@ -18,8 +18,10 @@ import asyncio
 from collections import OrderedDict
 from ray.util.queue import Queue
 from pretor.utils.ray_hook import ray_actor_hook
-from pretor.worker_individual.worker_individual import BaseIndividual, SkillIndividual, OrdinaryIndividual, \
+from pretor.worker_individual.base_individual import BaseIndividual
-    SpecialIndividual
+from pretor.worker_individual.skill_individual import SkillIndividual
+from pretor.worker_individual.ordinary_individual import OrdinaryIndividual
+from pretor.worker_individual.special_individual import SpecialIndividual
 
 
 from pretor.utils.logger import get_logger

pretor/worker_individual/worker_individual.py

@@ -1,157 +0,0 @@
-#  Copyright 2026 zhaoxi826
-#
-#  Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with the License.
-#  You may obtain a copy of the License at
-#
-#       http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-
-
-from pydantic_ai import Agent, RunContext
-from pydantic import Field
-from pretor.adapter.model_adapter.agent_factory import AgentFactory
-from pretor.core.global_state_machine.model_provider.base_provider import Provider
-from pretor.utils.agent_model import ResponseModel, InputModel, DepsModel
-from pretor.utils.ray_hook import ray_actor_hook
-
-
-from pretor.utils.logger import get_logger
-logger = get_logger('worker_individual')
-
-class WorkerIndividualResponse(ResponseModel):
-    output: str = Field(..., description="Worker执行任务的输出结果")
-
-
-class WorkerIndividualDeps(DepsModel):
-    task_event: dict
-
-
-class WorkerIndividualInput(InputModel):
-    task_event: dict
-
-
-class BaseIndividual:
-    """
-    Worker Individual 的基类
-    """
-
-    def __init__(self, agent_config: dict):
-        self.agent_config = agent_config
-        self.agent_id = agent_config.get("agent_id")
-        self.agent: Agent | None = None
-
-    async def _init_agent(self, agent_name: str, system_prompt: str):
-        global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
-        provider_title = self.agent_config.get("provider_title", "openai")  # default fallback
-        model_id = self.agent_config.get("model_id", "gpt-4o")  # default fallback
-
-        provider: Provider = await global_state_machine.get_provider.remote( provider_title)
-        agent_factory = AgentFactory()
-        self.agent = agent_factory.create_agent(
-            provider=provider,
-            model_id=model_id,
-            output_type=WorkerIndividualResponse,
-            system_prompt=system_prompt,
-            deps_type=WorkerIndividualDeps,
-            agent_name=agent_name
-        )
-
-        @self.agent.system_prompt
-        async def dynamic_prompt(ctx: RunContext[WorkerIndividualDeps]):
-            prompt = system_prompt + "\n\n"
-            prompt += (
-                f"=== 当前任务上下文 ===\n"
-                f"{ctx.deps.task_event}\n"
-            )
-            return prompt
-
-    async def run(self, task_event: dict) -> dict:
-        raise NotImplementedError("子类必须实现 run 方法")
-
-
-class SkillIndividual(BaseIndividual):
-    """
-    专家子个体：拥有专业 skill 的 agent。
-    """
-
-    def __init__(self, agent_config: dict):
-        super().__init__(agent_config)
-
-    async def run(self, task_event: dict) -> dict:
-        if self.agent is None:
-            system_prompt = self.agent_config.get("prompt",
-                                                  "你是一个拥有专业技能的专家级AI助手，请利用你的专业知识完成给定的任务。")
-            await self._init_agent("skill_individual", system_prompt)
-
-        deps = WorkerIndividualDeps(task_event=task_event)
-        self.agent.retries = 3
-        # In actual usage, tools could be dynamically loaded here based on agent_config
-        # tool = get_tool("skill_individual")
-        try:
-            result = await self.agent.run(
-                f"请执行以下任务：\n{task_event}",
-                deps=deps
-                # tools=tool
-            )
-            return {"output": result.data.output}
-        except Exception as e:
-            logger.exception(f"SkillIndividual {self.agent_id} 执行失败: {e}")
-            raise
-
-
-class OrdinaryIndividual(BaseIndividual):
-    """
-    普通子个体：普通的 agent。
-    """
-
-    def __init__(self, agent_config: dict):
-        super().__init__(agent_config)
-
-    async def run(self, task_event: dict) -> dict:
-        if self.agent is None:
-            system_prompt = self.agent_config.get("prompt", "你是一个普通的AI助手，请尽力完成给定的任务。")
-            await self._init_agent("ordinary_individual", system_prompt)
-
-        deps = WorkerIndividualDeps(task_event=task_event)
-        self.agent.retries = 3
-        try:
-            result = await self.agent.run(
-                f"请执行以下任务：\n{task_event}",
-                deps=deps
-            )
-            return {"output": result.data.output}
-        except Exception as e:
-            logger.exception(f"OrdinaryIndividual {self.agent_id} 执行失败: {e}")
-            raise
-
-
-class SpecialIndividual(BaseIndividual):
-    """
-    特殊子个体：执行特殊任务的 agent，如生成语音、视频等。
-    """
-
-    def __init__(self, agent_config: dict):
-        super().__init__(agent_config)
-
-    async def run(self, task_event: dict) -> dict:
-        if self.agent is None:
-            system_prompt = self.agent_config.get("prompt", "你是一个特殊的AI助手，负责处理特殊类型的任务。")
-            await self._init_agent("special_individual", system_prompt)
-
-        deps = WorkerIndividualDeps(task_event=task_event)
-        self.agent.retries = 3
-        try:
-            result = await self.agent.run(
-                f"请执行以下任务：\n{task_event}",
-                deps=deps
-            )
-            return {"output": result.data.output}
-        except Exception as e:
-            logger.exception(f"SpecialIndividual {self.agent_id} 执行失败: {e}")
-            raise

pyproject.toml

@@ -16,6 +16,7 @@ dependencies = [
     "pwdlib[argon2,bcrypt]>=0.3.0",
     "pydantic-ai>=1.73.0",
     "pyfiglet>=1.0.4",
+    "pyjwt>=2.12.1",
     "python-ulid>=3.1.0",
     "ray[default,serve]>=2.54.0",
     "rich>=14.3.3",

tests/core/global_state_machine/global_state_machine_test.py

@@ -50,23 +50,23 @@ def gsm(mock_postgres):
 
 def test_add_delete_get_event(gsm):
     event = MagicMock(spec=PretorEvent)
-    event.event_id = 123
+    event.trace_id = "123"
 
     gsm.add_event(event)
 
     assert getattr(event, 'pending_queue', None) is not None
     assert getattr(event, 'receive_queue', None) is not None
 
-    retrieved = gsm.get_event(123)
+    retrieved = gsm.get_event("123")
     assert retrieved == event
 
-    gsm.delete_event(123)
+    gsm.delete_event("123")
-    assert gsm.get_event(123) is None
+    assert gsm.get_event("123") is None
 
 
 def test_update_attachment_and_workflow(gsm):
     event = MagicMock(spec=PretorEvent)
-    event.event_id = "abc"
+    event.trace_id = "abc"
     gsm.add_event(event)
 
     gsm.update_attachment("abc", {"k": "v"})
@@ -80,7 +80,7 @@ def test_update_attachment_and_workflow(gsm):
 @pytest.mark.asyncio
 async def test_queues(gsm):
     event = MagicMock(spec=PretorEvent)
-    event.event_id = "q_event"
+    event.trace_id = "q_event"
     # To use await put/get, we must actually use real asyncio queues for the mock event
     event.pending_queue = asyncio.Queue()
     event.receive_queue = asyncio.Queue()

tests/core/workflow/workflow_test.py

@@ -10,41 +10,43 @@ def test_worker_group():
 def test_work_step():
     ws = WorkStep(
         step=1,
+        name="step1",
         node="control_node",
         action="coding",
         desc="Write some code"
     )
     assert ws.step == 1
+    assert ws.name == "step1"
     assert ws.node == "control_node"
     assert ws.action == "coding"
     assert ws.desc == "Write some code"
     assert ws.status == "waiting"
 
 def test_pretor_workflow_validation_success():
-    ws1 = WorkStep(step=1, node="control_node", action="a1", desc="d1")
+    ws1 = WorkStep(step=1, name="s1", node="control_node", action="a1", desc="d1")
-    ws2 = WorkStep(step=2, node="supervisory_node", action="a2", desc="d2")
+    ws2 = WorkStep(step=2, name="s2", node="supervisory_node", action="a2", desc="d2")
     wg = WorkerGroup(name="g1", primary_individual={"coder": 1}, composite_individual={})
     wf = PretorWorkflow(title="wf1", workgroup_list=[wg], work_link=[ws1, ws2], trace_id="t", event_info={"platform":"a", "user_name":"b"})
     assert wf.title == "wf1"
 
 def test_pretor_workflow_validation_error_step_discontinuous():
-    ws1 = WorkStep(step=1, node="control_node", action="a1", desc="d1")
+    ws1 = WorkStep(step=1, name="s1", node="control_node", action="a1", desc="d1")
-    ws2 = WorkStep(step=3, node="supervisory_node", action="a2", desc="d2")
+    ws2 = WorkStep(step=3, name="s3", node="supervisory_node", action="a2", desc="d2")
     wg = WorkerGroup(name="g1", primary_individual={}, composite_individual={})
     with pytest.raises(ValueError, match="工作链步数不连续"):
         PretorWorkflow(title="wf1", workgroup_list=[wg], work_link=[ws1, ws2], trace_id="t", event_info={"platform":"a", "user_name":"b"})
 
 def test_pretor_workflow_validation_error_jump_out_of_bounds():
     lg = LogicGate(if_fail="jump_to_step_3", if_pass="continue")
-    ws1 = WorkStep(step=1, node="control_node", action="a1", desc="d1", logic_gate=lg)
+    ws1 = WorkStep(step=1, name="s1", node="control_node", action="a1", desc="d1", logic_gate=lg)
-    ws2 = WorkStep(step=2, node="supervisory_node", action="a2", desc="d2")
+    ws2 = WorkStep(step=2, name="s2", node="supervisory_node", action="a2", desc="d2")
     wg = WorkerGroup(name="g1", primary_individual={}, composite_individual={})
     with pytest.raises(ValueError, match="跳转目标 Step 3 越界了"):
         PretorWorkflow(title="wf1", workgroup_list=[wg], work_link=[ws1, ws2], trace_id="t", event_info={"platform":"a", "user_name":"b"})
 
 def test_pretor_workflow_validation_error_jump_format_error():
     lg = LogicGate(if_fail="jump_to_step_invalid", if_pass="continue")
-    ws1 = WorkStep(step=1, node="control_node", action="a1", desc="d1", logic_gate=lg)
+    ws1 = WorkStep(step=1, name="s1", node="control_node", action="a1", desc="d1", logic_gate=lg)
     wg = WorkerGroup(name="g1", primary_individual={}, composite_individual={})
     with pytest.raises(ValueError, match="LogicGate 格式错误"):
         PretorWorkflow(title="wf1", workgroup_list=[wg], work_link=[ws1], trace_id="t", event_info={"platform":"a", "user_name":"b"})
@@ -53,4 +55,3 @@ def test_workflow_status():
     status = WorkflowStatus()
     assert status.step == 1
     assert status.status == "waiting_llm_working"
-    assert status.demand is None

uv.lock

@@ -3074,6 +3074,7 @@ dependencies = [
     { name = "pydantic-ai", version = "1.75.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.14'" },
     { name = "pydantic-ai", version = "1.84.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.14'" },
     { name = "pyfiglet" },
+    { name = "pyjwt" },
     { name = "python-ulid" },
     { name = "ray", extra = ["default", "serve"] },
     { name = "rich" },
@@ -3105,6 +3106,7 @@ requires-dist = [
     { name = "pwdlib", extras = ["argon2", "bcrypt"], specifier = ">=0.3.0" },
     { name = "pydantic-ai", specifier = ">=1.73.0" },
     { name = "pyfiglet", specifier = ">=1.0.4" },
+    { name = "pyjwt", specifier = ">=2.12.1" },
     { name = "python-ulid", specifier = ">=3.1.0" },
     { name = "ray", extras = ["default", "serve"], specifier = ">=2.54.0" },
     { name = "rich", specifier = ">=14.3.3" },