diff options
| -rw-r--r-- | guix-build-coordinator/build-allocator.scm | 2 | ||||
| -rw-r--r-- | guix-build-coordinator/datastore/sqlite.scm | 5 |
2 files changed, 4 insertions, 3 deletions
diff --git a/guix-build-coordinator/build-allocator.scm b/guix-build-coordinator/build-allocator.scm index fda893c..58ae6ef 100644 --- a/guix-build-coordinator/build-allocator.scm +++ b/guix-build-coordinator/build-allocator.scm @@ -342,7 +342,7 @@ build-ids-for-unprocessed-builds-with-built-inputs) (datastore-call-with-transaction datastore - (lambda () + (lambda (db) (values (datastore-fetch-unprocessed-builds-with-propagated-priorities datastore) (datastore-list-unprocessed-builds-with-built-inputs datastore))) diff --git a/guix-build-coordinator/datastore/sqlite.scm b/guix-build-coordinator/datastore/sqlite.scm index 6a49f19..6afa872 100644 --- a/guix-build-coordinator/datastore/sqlite.scm +++ b/guix-build-coordinator/datastore/sqlite.scm @@ -132,7 +132,7 @@ result)) (thunk))) -(define* (datastore-call-with-transaction datastore thunk +(define* (datastore-call-with-transaction datastore proc #:key readonly?) (call-with-worker-thread (slot-ref datastore (if readonly? @@ -149,7 +149,8 @@ (raise-exception exn)) (lambda () (call-with-values - thunk + (lambda () + (proc db)) (lambda vals (sqlite-exec db "COMMIT TRANSACTION;") (apply values vals)))) |