fix: 修复了actor调用问题
This commit is contained in:
parent
fa22999d8c
commit
65652399e0
|
|
@ -111,7 +111,7 @@ 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:
|
||||||
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)
|
await workflow_running_engine.put_event.remote(payload)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
self.logger.error(f"SupervisoryNode: 无法将事件放入 WorkflowRunningEngine: {e}")
|
self.logger.error(f"SupervisoryNode: 无法将事件放入 WorkflowRunningEngine: {e}")
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue