Fix metrics for fallback jobs

livepeer · Sep 12, 2023 · aa42440 · aa42440
1 parent c81f282
commit aa42440
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pipeline/coordinator.go b/pipeline/coordinator.go
@@ -556,7 +556,7 @@ func (c *Coordinator) finishJob(job *JobInfo, out *HandlerOutput, err error) {
 		WithLabelValues(labels...).
 		Add(float64(job.transcodedSegments))
 
-	go c.sendDBMetrics(job, out)
+	c.sendDBMetrics(job, out)
 
 	job.result <- success
 }