fix: 工作流引擎接受 ForregulatoryNode 类型返回,修复最后一步失败
consciousness_node 在总结步骤返回 ForregulatoryNode 类型,但工作流引擎 只认 ForWorkflow 导致最后一步标记 failed。现在两种类型都被正确处理。 Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user