diff --git a/pkg/starter/starter.go b/pkg/starter/starter.go
index f5284a9..09abfa7 100644
--- a/pkg/starter/starter.go
+++ b/pkg/starter/starter.go
@@ -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
 					}