Skip to content

Commit

Permalink
Merge pull request #181 from takonomura/fix-rescuing
Browse files Browse the repository at this point in the history
Fix re-rescuing jobs
  • Loading branch information
whywaita authored Sep 29, 2023
2 parents ed56517 + 9796f4e commit b0d2e46
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/starter/starter.go
Original file line number Diff line number Diff line change
Expand Up @@ -366,7 +366,7 @@ func (s *Starter) reRunWorkflow(ctx context.Context) {
if value, ok := reQueuedJobs.Load(j.GetID()); ok {
expired := value.(time.Time)
if time.Until(expired) <= 0 {
reQueuedJobs.Delete(run.GetID())
reQueuedJobs.Delete(j.GetID())
}
continue
}
Expand Down

0 comments on commit b0d2e46

Please sign in to comment.