fix(router): retry backoff causing out-of-order job processing (#3098)

rudderlabs · Mar 14, 2023 · eda4525 · eda4525
1 parent ea3bbd5
commit eda4525
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/router/router.go b/router/router.go
@@ -1212,7 +1212,8 @@ func (rt *HandleT) findWorker(job *jobsdb.JobT, throttledOrderKeys map[string]st
 	//#JobOrder (see other #JobOrder comment)
 	index := rt.getWorkerPartition(orderKey)
 	worker := rt.workers[index]
-	if time.Until(job.LastJobStatus.RetryTime) > 0 { // backoff
+	if job.LastJobStatus.JobState == jobsdb.Failed.State && job.LastJobStatus.AttemptNum > 0 && time.Until(job.LastJobStatus.RetryTime) > 0 { // backoff
+		throttledOrderKeys[orderKey] = struct{}{}
 		return
 	}
 	enter, previousFailedJobID := worker.barrier.Enter(orderKey, job.JobID)