A finished stage can unlock a pending one

2026-01-30 02:06:39 +00:00 · 2019-06-21 11:52:36 +02:00
parent be94151c0e
commit 788973d0d1
1 changed files with 1 additions and 0 deletions
--- 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
 }