diff options
| author | Ivar Refsdal <refsdal.ivar@gmail.com> | 2022-03-28 19:56:37 +0200 |
|---|---|---|
| committer | Ivar Refsdal <refsdal.ivar@gmail.com> | 2022-03-28 19:56:37 +0200 |
| commit | fc6dbf142005c57623cd1386a576b1fb487ac44a (patch) | |
| tree | ad189d98e2d5777ceb8f27aa4c003073ed3eb4f7 /src | |
| parent | Release 0.2.48 (diff) | |
| download | fiinha-fc6dbf142005c57623cd1386a576b1fb487ac44a.tar.gz fiinha-fc6dbf142005c57623cd1386a576b1fb487ac44a.tar.xz | |
Don't OOM on migrating large datasets. Always prefer user specified value for config, also for `false`/`nil` values.
Diffstat (limited to 'src')
| -rw-r--r-- | src/com/github/ivarref/yoltq.clj | 2 | ||||
| -rw-r--r-- | src/com/github/ivarref/yoltq/migrate.clj | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/com/github/ivarref/yoltq.clj b/src/com/github/ivarref/yoltq.clj index 4b324c4..e1fd1b0 100644 --- a/src/com/github/ivarref/yoltq.clj +++ b/src/com/github/ivarref/yoltq.clj @@ -80,7 +80,7 @@ @(d/transact conn i/schema) (let [new-cfg (swap! *config* (fn [old-conf] - (-> (merge-with (fn [a b] (or b a)) + (-> (merge-with (fn [_ b] b) {:running-queues (atom #{}) :start-execute-time (atom {}) :system-error (atom {}) diff --git a/src/com/github/ivarref/yoltq/migrate.clj b/src/com/github/ivarref/yoltq/migrate.clj index 89fc286..6313b73 100644 --- a/src/com/github/ivarref/yoltq/migrate.clj +++ b/src/com/github/ivarref/yoltq/migrate.clj @@ -47,7 +47,7 @@ (let [tx (to->v2-ent cfg now-ms id)] @(d/transact conn tx) (if loop? - (recur (conj tx-vec tx)) + (recur (vec (take 10 (conj tx-vec tx)))) tx)) (do (log/info "No items left to migrate") |