diff --git a/pipeline/coordinator.go b/pipeline/coordinator.go
index 76cf558e3..abddffb8e 100644
--- 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
 }