From 65652399e016a185c1c33402bafbd93f2664b2ac Mon Sep 17 00:00:00 2001 From: zhaoxi Date: Tue, 28 Apr 2026 14:25:48 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E4=BA=86actor?= =?UTF-8?q?=E8=B0=83=E7=94=A8=E9=97=AE=E9=A2=98?= 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, 1 insertion(+), 1 deletion(-) diff --git a/pretor/core/individual/supervisory_node/supervisory_node.py b/pretor/core/individual/supervisory_node/supervisory_node.py index c4d4645..ec42f29 100644 --- a/pretor/core/individual/supervisory_node/supervisory_node.py +++ b/pretor/core/individual/supervisory_node/supervisory_node.py @@ -111,7 +111,7 @@ class SupervisoryNode: if isinstance(payload, PretorEvent): payload.context["workflow_template"] = result.workflow_template try: - workflow_running_engine = ray_actor_hook("workflow_running_engine") + workflow_running_engine = ray_actor_hook("workflow_running_engine").workflow_running_engine await workflow_running_engine.put_event.remote(payload) except Exception as e: self.logger.error(f"SupervisoryNode: 无法将事件放入 WorkflowRunningEngine: {e}")