From a124812f218a653093ee702966ea1f6de99cd53c Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Wed, 13 Aug 2025 11:47:11 +0200 Subject: [PATCH] WIP --- backend/src/app/srepl/main.clj | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/backend/src/app/srepl/main.clj b/backend/src/app/srepl/main.clj index f4f96bbd68..941fbfdff4 100644 --- a/backend/src/app/srepl/main.clj +++ b/backend/src/app/srepl/main.clj @@ -577,18 +577,16 @@ (l/dbg :hint "start job thread" :jid jid) (px/sleep 1000) - (loop [total 0] + (loop [] (let [result (-> main/system (assoc ::db/rollback rollback?) (proc-fn opts))] - (l/dbg :hint "chunk processed" :jid jid :total total :chunk 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) (< total max-items)) - (recur total))))))] + (recur))))))] (l/dbg :hint "process:start" :rollback rollback?