Fix re-rescuing jobs

whywaita · Sep 27, 2023 · 9796f4e · 9796f4e
1 parent 3248887
commit 9796f4e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/starter/starter.go b/pkg/starter/starter.go
@@ -358,7 +358,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
 					}