Do DB rollback on failed build insert

2021-03-25 10:42:04 +01:00 · 2021-03-25 10:42:04 +01:00 · 265e00a718
commit 265e00a718
parent 7b5119189d
1 changed files with 8 additions and 1 deletions
--- a/lib/model.ml
+++ b/lib/model.ml
@ -223,4 +223,11 @@ let add_build
    Db.commit () >>= fun () ->
    commit_files basedir staging_dir job_name uuid
  in
-  or_cleanup r
+  Lwt_result.bind_lwt_err (or_cleanup r)
+    (fun e ->
+       Db.rollback ()
+       |> Lwt.map (fun r ->
+           Result.iter_error
+             (fun e' -> Log.err (fun m -> m "Failed rollback: %a" Caqti_error.pp e'))
+             r;
+           e))