Always log at top level when pipeline errors (#917)

livepeer · Oct 12, 2023 · d80308f · d80308f
1 parent c5cd1c2
commit d80308f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pipeline/coordinator.go b/pipeline/coordinator.go
@@ -4,7 +4,6 @@ import (
 	"crypto/rsa"
 	"database/sql"
 	"fmt"
-	"github.com/cenkalti/backoff/v4"
 	"math"
 	"net/url"
 	"os"
@@ -15,6 +14,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/cenkalti/backoff/v4"
+
 	_ "github.com/lib/pq"
 	"github.com/livepeer/catalyst-api/cache"
 	"github.com/livepeer/catalyst-api/clients"
@@ -522,6 +523,9 @@ func (c *Coordinator) runHandlerAsync(job *JobInfo, handler func() (*HandlerOutp
 
 		out, err := recovered(handler)
 		if err != nil || (out != nil && !out.Continue) {
+			if err != nil {
+				log.LogError(job.RequestID, "error running job handler", err)
+			}
 			c.finishJob(job, out, err)
 		}
 		// dummy