From c2ea2d9d0dbac74f69170c3f58a0e8ab970be7c2 Mon Sep 17 00:00:00 2001 From: Bryce Covert Date: Mon, 4 Nov 2019 18:25:03 -0800 Subject: [PATCH] batching --- src/clj/auto_ap/graphql/ledger.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/clj/auto_ap/graphql/ledger.clj b/src/clj/auto_ap/graphql/ledger.clj index 614d2fe7..611c268c 100644 --- a/src/clj/auto_ap/graphql/ledger.clj +++ b/src/clj/auto_ap/graphql/ledger.clj @@ -235,8 +235,8 @@ success (filter (comp not :error) transaction) retraction (mapv (fn [x] [:db/retractEntity [:journal-entry/external-id (:journal-entry/external-id x)]]) success)] - @(d/transact (d/connect uri) retraction) - @(d/transact (d/connect uri) success) + (run! (fn [batch] (println "transacting retraction batch") @(d/transact (d/connect uri) batch)) (partition-all 100 retraction)) + (run! (fn [batch] (println "transacting success batch") @(d/transact (d/connect uri) batch)) (partition-all 100 success)) {:successful (map (fn [x] {:external_id (:journal-entry/external-id x)}) success) :existing [] :errors (map (fn [x] {:external_id (:external_id x)