Skip to content

Commit cd87dd9

Browse files
committed
fix: Hook issue replication issue in distributed workflows
1 parent 65bf4ee commit cd87dd9

File tree

1 file changed

+11
-5
lines changed

1 file changed

+11
-5
lines changed

shared.go

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6554,19 +6554,25 @@ func diffWorkflows(oldWorkflow Workflow, parentWorkflow Workflow, update bool) {
65546554
}
65556555
}
65566556

6557-
6558-
for _, trigger := range childWorkflow.Triggers {
6559-
6557+
replacedTriggers := []string{}
6558+
for _, trigger := range oldWorkflow.Triggers {
6559+
if len(trigger.ReplacementForTrigger) > 0 {
6560+
replacedTriggers = append(replacedTriggers, trigger.ReplacementForTrigger)
6561+
}
6562+
}
65606563

65616564
if len(addedTriggers) > 0 {
6562-
log.Printf("[DEBUG] Triggers added: %d", len(addedTriggers))
65636565
triggers := childTriggers
65646566
for _, trigger := range parentWorkflow.Triggers {
65656567
if !ArrayContains(addedTriggers, trigger.ID) {
65666568
continue
65676569
}
65686570

6569-
log.Printf("[DEBUG] ID of the added trigger: %s", trigger.ID)
6571+
if ArrayContains(replacedTriggers, trigger.ID) {
6572+
continue
6573+
}
6574+
6575+
// log.Printf("[DEBUG] ID of the added trigger: %s", trigger.ID)
65706576

65716577
triggers = append(triggers, trigger)
65726578
}

0 commit comments

Comments
 (0)