From 0ee8139902d40b78e541be4febf8ff960e74a3a2 Mon Sep 17 00:00:00 2001 From: zhaoxi Date: Tue, 28 Apr 2026 14:57:32 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E4=BA=86=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pretor/core/individual/supervisory_node/supervisory_node.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pretor/core/individual/supervisory_node/supervisory_node.py b/pretor/core/individual/supervisory_node/supervisory_node.py index ec42f29..32809af 100644 --- a/pretor/core/individual/supervisory_node/supervisory_node.py +++ b/pretor/core/individual/supervisory_node/supervisory_node.py @@ -111,6 +111,8 @@ class SupervisoryNode: if isinstance(payload, PretorEvent): payload.context["workflow_template"] = result.workflow_template 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 await workflow_running_engine.put_event.remote(payload) except Exception as e: