We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2d28ea4 commit 587c7b3Copy full SHA for 587c7b3
1 file changed
sdk/src/lib.rs
@@ -410,6 +410,15 @@ impl WorkflowHalf {
410
Some(Variant::InitializeWorkflow(ref mut sw)) => Some(sw),
411
_ => None,
412
}) {
413
+ if self.workflows.borrow().contains_key(&run_id) {
414
+ // Duplicate init for the same run. Forward to existing workflow.
415
+ if let Some(dat) = self.workflows.borrow_mut().get_mut(&run_id) {
416
+ dat.activation_chan
417
+ .send(activation)
418
+ .expect("Workflow should exist if we're sending it an activation");
419
+ }
420
+ return Ok(None);
421
422
let workflow_type = &sw.workflow_type;
423
let wf_fns_borrow = self.workflow_fns.borrow();
424
let Some(wf_function) = wf_fns_borrow.get(workflow_type) else {
0 commit comments