fix

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()
 }