fixup! send consistent status update to scheduler

grafana · Jan 9, 2025 · aa59ac1 · aa59ac1
1 parent 44b515f
commit aa59ac1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/blockbuilder/builder/builder.go b/pkg/blockbuilder/builder/builder.go
@@ -279,8 +279,7 @@ func (i *BlockBuilder) runOne(ctx context.Context, c *kgo.Client, workerID strin
 		completion.Success = false
 	}
 
-	// remove from inflight jobs to stop sending updates for this job
-	// to avoid race with completed job requests.
+	// remove from inflight jobs to stop sending sync requests
 	i.jobsMtx.Lock()
 	delete(i.inflightJobs, job.ID())
 	i.metrics.inflightJobs.Set(float64(len(i.inflightJobs)))