fix: illegal job sequence during barrier enter in router pickup (#3737)

rudderlabs · Aug 10, 2023 · 5017146 · 5017146
1 parent 48f1717
commit 5017146
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/router/handle.go b/router/handle.go
@@ -532,6 +532,7 @@ func (rt *Handle) findWorkerSlot(workers []*worker, job *jobsdb.JobT, blockedOrd
 	}
 	rt.logger.Debugf("EventOrder: job %d of orderKey %s is blocked (previousFailedJobID: %s)", job.JobID, orderKey, previousFailedJobIDStr)
 	slot.Release()
+	blockedOrderKeys[orderKey] = struct{}{}
 	return nil, types.ErrBarrierExists
 	//#EndJobOrder
 }