check match on enqueueing next job for partition

grafana · Jan 3, 2025 · 3ee784c · 3ee784c
1 parent 7235e37
commit 3ee784c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/blockbuilder/scheduler/scheduler.go b/pkg/blockbuilder/scheduler/scheduler.go
@@ -263,7 +263,7 @@ func (s *BlockScheduler) HandleCompleteJob(ctx context.Context, job *types.Job,
 				return jobs[i].Job.Partition() >= job.Partition()
 			})
 
-			if nextJob < len(jobs) {
+			if nextJob < len(jobs) && jobs[nextJob].Job.Partition() == job.Partition() {
 				_, _, _ = s.idempotentEnqueue(jobs[nextJob])
 			}