From a4833f95b51959c63e071ce0d19d90734bb25e8b Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Wed, 13 Aug 2025 11:26:41 +0200 Subject: [PATCH] WIP --- backend/src/app/srepl/main.clj | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/backend/src/app/srepl/main.clj b/backend/src/app/srepl/main.clj index 7683820b54..04f3b16a19 100644 --- a/backend/src/app/srepl/main.clj +++ b/backend/src/app/srepl/main.clj @@ -560,14 +560,10 @@ rollback? true} :as opts}] - (l/dbg :hint "process:start" - :rollback rollback? - :max-jobs max-jobs - :max-chunks max-chunks) - - (let [tpoint (ct/tpoint) - max-jobs (or max-jobs (px/get-available-processors)) - chunks (atom 0) + (let [tpoint (ct/tpoint) + max-jobs (or max-jobs (px/get-available-processors)) + max-chunks (max max-chunks max-jobs) + processed (atom 0) start-job (fn [jid] @@ -579,13 +575,18 @@ (assoc ::db/rollback rollback?) (proc-fn opts)) total (+ total result) - chunks (swap! chunks inc)] + chunks (swap! processed inc)] (l/dbg :hint "chunk processed" :jid jid :total total :chunk result) (when (and (pos? result) (< chunks max-chunks)) (recur total)))))] + (l/dbg :hint "process:start" + :rollback rollback? + :max-jobs max-jobs + :max-chunks max-chunks) + (try (let [jobs (->> (range max-jobs) (map (fn [jid] (px/fn->thread (partial start-job jid))))