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: