diff --git a/kilostar/core/work/workflow/workflow_engine.py b/kilostar/core/work/workflow/workflow_engine.py index 7088131..4daac51 100644 --- a/kilostar/core/work/workflow/workflow_engine.py +++ b/kilostar/core/work/workflow/workflow_engine.py @@ -399,6 +399,7 @@ async def _default_consciousness_executor( from kilostar.core.individual.consciousness_node.template import ( ForWorkflow, ForWorkflowInput, + ForregulatoryNode, ) from kilostar.core.work.workflow.workflow import WorkflowStep @@ -410,6 +411,8 @@ async def _default_consciousness_executor( result = await consciousness_node.working.remote(payload) if isinstance(result, ForWorkflow): return result.output, True + if isinstance(result, ForregulatoryNode): + return result.output, True if result is None: return "ConsciousnessNode 返回 None", False return f"ConsciousnessNode 返回未知类型: {type(result).__name__}", False