zhaoxi
/
Pretor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 修复了逻辑

This commit is contained in:
朝夕 2026-04-28 14:57:32 +08:00
parent 65652399e0
commit 0ee8139902
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pretor/core/individual/supervisory_node/supervisory_node.py
View File

@ -111,6 +111,8 @@ class SupervisoryNode:
if isinstance(payload, PretorEvent): if isinstance(payload, PretorEvent):
payload.context["workflow_template"] = result.workflow_template payload.context["workflow_template"] = result.workflow_template
try: try:
global_state_machine = ray_actor_hook("global_state_machine").global_state_machine
await global_state_machine.add_event.remote(payload)
workflow_running_engine = ray_actor_hook("workflow_running_engine").workflow_running_engine workflow_running_engine = ray_actor_hook("workflow_running_engine").workflow_running_engine
await workflow_running_engine.put_event.remote(payload) await workflow_running_engine.put_event.remote(payload)
except Exception as e: except Exception as e: