diff --git a/zq/zq.go b/zq/zq.go index 6aa4499fda98febb173f5a00971beae68f403dcf..f00b22ce012f3b9b10adb31786461b40d458b821 100644 --- a/zq/zq.go +++ b/zq/zq.go @@ -117,6 +117,13 @@ func (q *ZQ) AddJob(a any) error { return nil } +func (q *ZQ) AddJobForce(a any) error { + q.ZQuit.Inc() + q.jobs <- a + + return nil +} + func (q *ZQ) Wait() { q.ZQuit.Wait() }