From 9796f4eb6dab0fcede7ab301a2dcb27c7af1e8ee Mon Sep 17 00:00:00 2001
From: takonomura <takonomura@users.noreply.github.com>
Date: Wed, 27 Sep 2023 10:43:56 +0900
Subject: [PATCH] Fix re-rescuing jobs

---
 pkg/starter/starter.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/starter/starter.go b/pkg/starter/starter.go
index 1bf4366..dc00265 100644
--- 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
 					}