refactor: remove payload from notify_done workflow signal

main
Cizz22 2 months ago
parent 7df6a24cbc
commit 6f5b757a93

@ -91,10 +91,7 @@ class SimulationWorkflow:
client = await Client.connect(TEMPORAL_URL) client = await Client.connect(TEMPORAL_URL)
handle = client.get_workflow_handle(sim_data["CallbackWorkflowId"]) handle = client.get_workflow_handle(sim_data["CallbackWorkflowId"])
await handle.signal("notify_done", { await handle.signal("notify_done")
"simulation_id": sim_data["HubCnnId"],
"status": "success"
})
return sim_data["HubCnnId"] # simulation_id return sim_data["HubCnnId"] # simulation_id

Loading…
Cancel
Save