diff --git a/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj b/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
index bdb06cab..51587508 100644
--- a/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
+++ b/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
@@ -6,11 +6,11 @@
             [auto-ap.ledger :as ledger]))
 
 (defn test-run [txs-set]
-  (println "processing " (count txs-set))
+  #_(println "processing " (count txs-set))
   (doseq [[i tx] (map vector (range) txs-set)]
     @(d/transact (d/connect auto-ap.datomic/uri)
                 tx)
-    (when (= 0 (mod i 1000))
+    (when (= 0 (mod i 100))
       (println "processed " i))))
 
 
@@ -218,7 +218,6 @@
                                                  :in '[$]
                                                  :where ['[?e :transaction/id]]}
                                          :args [(d/db conn)]}))
-        _ (println (count transaction-ids))
         z (->> transaction-ids
                (map #(ledger/entity-change->ledger (d/db conn) [:transaction %]))
                (filter identity)
@@ -438,7 +437,7 @@
                                        :in '[$]
                                        :where ['[?e :journal-entry/original-entity ]]}
                                :args [(d/db conn)]})
-                     (mapv (fn [[id]]
+                     (map (fn [[id]]
                              [:db/retractEntity id]))
                      (partition-all 100))]
     results))
diff --git a/src/clj/auto_ap/ledger.clj b/src/clj/auto_ap/ledger.clj
index 1ef1cab9..099677d2 100644
--- a/src/clj/auto_ap/ledger.clj
+++ b/src/clj/auto_ap/ledger.clj
@@ -141,8 +141,11 @@
       #_(println "updating general-ledger " d-tx)
       @(d/transact (d/connect uri) [d-tx]))))
 
+(def break (atom false))
+
 (defn process-all []
-  (while (not (Thread/interrupted))
+  (while (and (not @break)
+              (not (Thread/interrupted)))
     (process-one (d/tx-report-queue (d/connect uri) ))))