From aa42440601f0dc44828bb46d5b0746e9d0cd10cf Mon Sep 17 00:00:00 2001
From: Max Holland <max@livepeer.org>
Date: Fri, 8 Sep 2023 11:43:47 +0100
Subject: [PATCH] Fix metrics for fallback jobs

---
 pipeline/coordinator.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
 }