This commit is contained in:
Andrey Antukh
2025-08-13 11:47:11 +02:00
parent f75b7ea284
commit a124812f21

View File

@@ -577,18 +577,16 @@
(l/dbg :hint "start job thread" :jid jid) (l/dbg :hint "start job thread" :jid jid)
(px/sleep 1000) (px/sleep 1000)
(loop [total 0] (loop []
(let [result (-> main/system (let [result (-> main/system
(assoc ::db/rollback rollback?) (assoc ::db/rollback rollback?)
(proc-fn opts))] (proc-fn opts))]
(l/dbg :hint "chunk processed" :jid jid :total total :chunk result)
(let [total (swap! processed + result)] (let [total (swap! processed + result)]
(l/dbg :hint "chunk processed" :jid jid :total total :chunk result) (l/dbg :hint "chunk processed" :jid jid :total total :chunk result ::l/sync? true)
(when (and (pos? result) (when (and (pos? result)
(< total max-items)) (< total max-items))
(recur total))))))] (recur))))))]
(l/dbg :hint "process:start" (l/dbg :hint "process:start"
:rollback rollback? :rollback rollback?