From b237ba8ea85849d2d6939b62c727a4511825e12e Mon Sep 17 00:00:00 2001 From: Tim McGilchrist Date: Fri, 13 Oct 2023 12:22:25 +1100 Subject: [PATCH] fixup! Try using Lwt_preemptive detached thread. --- src/lib/misc.ml | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/src/lib/misc.ml b/src/lib/misc.ml index 121a40c4..2e9f5a82 100644 --- a/src/lib/misc.ml +++ b/src/lib/misc.ml @@ -70,10 +70,15 @@ module PeekerBody = struct let open Lwt.Syntax in let* () = Current.Job.start ~level:Current.Level.Mostly_harmless job in Current.Job.log job "tag: %s" (tag key); - let r : (Docker_hub.t, Docker_hub.fetch_errors) result Lwt.t - = Lwt_preemptive.(detach - (fun () -> run_in_main - (fun _t -> Docker_hub.fetch_manifests ~repo:"ocaml/opam" ~tag:(Some (tag key)))) ()) in + let r : (Docker_hub.t, Docker_hub.fetch_errors) result Lwt.t = + Lwt_preemptive.( + detach + (fun () -> + run_in_main (fun _t -> + Docker_hub.fetch_manifests ~repo:"ocaml/opam" + ~tag:(Some (tag key)))) + ()) + in (* let+ res = *) (* Docker_hub.fetch_manifests ~repo:"ocaml/opam" ~tag:(Some (tag key)) *) (* in *)