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)