fix: schedule trigger not starting for distributed workflows

Shuffle · Dec 19, 2024 · 15ad3b3 · 15ad3b3
1 parent cd87dd9
commit 15ad3b3
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/shared.go b/shared.go
@@ -9707,6 +9707,22 @@ func GenerateWorkflowFromParent(ctx context.Context, workflow Workflow, parentOr
 					}
 				}
 			}
+		} else if newWf.Triggers[triggerIndex].TriggerType == "SCHEDULE" {
+			oldID := newWf.Triggers[triggerIndex].ID
+			newWf.Triggers[triggerIndex].ID = uuid.NewV4().String()
+
+			newWf.Triggers[triggerIndex].ReplacementForTrigger = oldID	
+
+
+			for branchIndex, branch := range newWf.Branches {
+				if branch.SourceID == oldID {
+					newWf.Branches[branchIndex].SourceID = newWf.Triggers[triggerIndex].ID
+				}
+
+				if branch.DestinationID == oldID {
+					newWf.Branches[branchIndex].DestinationID = newWf.Triggers[triggerIndex].ID
+				}
+			}
 		}
 	}