fix: remove timed out step runs from queue

hatchet-dev · Aug 7, 2024 · 88406ad · 88406ad
1 parent ad83a3d
commit 88406ad
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/repository/prisma/step_run.go b/pkg/repository/prisma/step_run.go
@@ -1109,6 +1109,8 @@ func (s *stepRunEngineRepository) QueueStepRuns(ctx context.Context, tenantId st
 
 		if isTimedOut {
 			timedOutStepRuns = append(timedOutStepRuns, qi.StepRunId)
+			// mark as queued so that we don't requeue
+			queuedItems = append(queuedItems, qi.ID)
 			continue
 		}