refactor: use workflow.get_external_workflow_handle instead of manual client connection for signaling callbacks

2 months ago · 9bdfaa67c8
parent 6f5b757a93
commit 9bdfaa67c8
1 changed files with 3 additions and 3 deletions
--- a/temporal/workflow.py
+++ b/temporal/workflow.py
@ -88,9 +88,9 @@ class SimulationWorkflow:
        )
        if sim_data.get("CallbackWorkflowId"):
-            client = await Client.connect(TEMPORAL_URL)
+            handle = workflow.get_external_workflow_handle(
-            handle = client.get_workflow_handle(sim_data["CallbackWorkflowId"])
+                sim_data["CallbackWorkflowId"]
-
+            )
            await handle.signal("notify_done")