diff --git a/cncd/queue/fifo.go b/cncd/queue/fifo.go index 43d0c5097..381631b0f 100644 --- a/cncd/queue/fifo.go +++ b/cncd/queue/fifo.go @@ -107,6 +107,7 @@ func (q *fifo) Error(c context.Context, id string, err error) error { q.removeFromPending(id) } q.Unlock() + go q.process() return nil }