diff --git a/server/queue/fifo.go b/server/queue/fifo.go index f86c2a866..086f1644f 100644 --- a/server/queue/fifo.go +++ b/server/queue/fifo.go @@ -17,7 +17,6 @@ package queue import ( "container/list" "context" - "runtime" "sync" "time" @@ -241,17 +240,6 @@ func (q *fifo) process() { return } - defer func() { - // the risk of panic is low. This code can probably be removed - // once the code has been used in real world installs without issue. - if err := recover(); err != nil { - const size = 64 << 10 - buf := make([]byte, size) - buf = buf[:runtime.Stack(buf, false)] - log.Error().Msgf("queue: unexpected panic: %v\n%s", err, buf) - } - }() - q.resubmitExpiredPipelines() q.filterWaiting() for pending, worker := q.assignToWorker(); pending != nil && worker != nil; pending, worker = q.assignToWorker() {