diff --git a/src/ambient-context/opentelemetry_ambient_context.mli b/src/ambient-context/opentelemetry_ambient_context.mli
index 4cb1cc51..8f19ff0c 100644
--- a/src/ambient-context/opentelemetry_ambient_context.mli
+++ b/src/ambient-context/opentelemetry_ambient_context.mli
@@ -2,23 +2,24 @@
 
     The ambient context, like the Matrix, is everywhere around you.
 
-    It is responsible for keeping track of that context in a manner that's consistent with
-    the program's choice of control flow paradigm:
+    It is responsible for keeping track of that context in a manner that's
+    consistent with the program's choice of control flow paradigm:
 
-    - for synchronous/threaded/direct style code, {b TLS} ("thread local storage") keeps
-      track of a global variable per thread. Each thread has its own copy of the variable
-      and updates it independently of other threads.
+    - for synchronous/threaded/direct style code, {b TLS} ("thread local
+      storage") keeps track of a global variable per thread. Each thread has its
+      own copy of the variable and updates it independently of other threads.
 
-    - for Lwt, any ['a Lwt.t] created inside the [with_binding k v (fun _ -> …)] will
-      inherit the [k := v] assignment.
+    - for Lwt, any ['a Lwt.t] created inside the [with_binding k v (fun _ -> …)]
+      will inherit the [k := v] assignment.
 
-    - for Eio, fibers created inside [with_binding k v (fun () -> …)] will inherit the
-      [k := v] assignment. This is consistent with the structured concurrency approach of
-      Eio.
+    - for Eio, fibers created inside [with_binding k v (fun () -> …)] will
+      inherit the [k := v] assignment. This is consistent with the structured
+      concurrency approach of Eio.
 
-    The only data stored by this storage is a {!Hmap.t}, ie a heterogeneous map. Various
-    users (libraries, user code, etc.) can create their own {!key} to store what they are
-    interested in, without affecting other parts of the storage. *)
+    The only data stored by this storage is a {!Hmap.t}, ie a heterogeneous map.
+    Various users (libraries, user code, etc.) can create their own {!key} to
+    store what they are interested in, without affecting other parts of the
+    storage. *)
 
 module Types := Opentelemetry_ambient_context_types
 
@@ -42,13 +43,13 @@ val create_key : unit -> 'a key
 (** Create a new fresh key, distinct from any previously created key. *)
 
 val get : 'a key -> 'a option
-(** Get the current value for a given key, or [None] if no value was associated with the
-    key in the ambient context. *)
+(** Get the current value for a given key, or [None] if no value was associated
+    with the key in the ambient context. *)
 
 val with_binding : 'a key -> 'a -> (unit -> 'r) -> 'r
-(** [with_binding k v cb] calls [cb()] in a context in which [k] is bound to [v]. This
-    does not affect storage outside of [cb()]. *)
+(** [with_binding k v cb] calls [cb()] in a context in which [k] is bound to
+    [v]. This does not affect storage outside of [cb()]. *)
 
 val without_binding : 'a key -> (unit -> 'b) -> 'b
-(** [without_binding k cb] calls [cb()] in a context where [k] has no binding (possibly
-    shadowing the current ambient binding of [k] if it exists). *)
+(** [without_binding k cb] calls [cb()] in a context where [k] has no binding
+    (possibly shadowing the current ambient binding of [k] if it exists). *)
diff --git a/src/ambient-context/types/opentelemetry_ambient_context_types.mli b/src/ambient-context/types/opentelemetry_ambient_context_types.mli
index cded6589..738b7520 100644
--- a/src/ambient-context/types/opentelemetry_ambient_context_types.mli
+++ b/src/ambient-context/types/opentelemetry_ambient_context_types.mli
@@ -1,7 +1,7 @@
 (** Storage implementation.
 
-    There is a singleton storage for a given program, responsible for providing ambient
-    context to the rest of the program. *)
+    There is a singleton storage for a given program, responsible for providing
+    ambient context to the rest of the program. *)
 
 type 'a key = 'a Hmap.key
 
@@ -10,15 +10,17 @@ module type STORAGE = sig
   (** Name of the storage implementation. *)
 
   val get_map : unit -> Hmap.t option
-  (** Get the hmap from the current ambient context, or [None] if there is no ambient
-      context. *)
+  (** Get the hmap from the current ambient context, or [None] if there is no
+      ambient context. *)
 
   val with_map : Hmap.t -> (unit -> 'b) -> 'b
-  (** [with_hmap h cb] calls [cb()] in an ambient context in which [get_map()] will return
-      [h]. Once [cb()] returns, the storage is reset to its previous value. *)
+  (** [with_hmap h cb] calls [cb()] in an ambient context in which [get_map()]
+      will return [h]. Once [cb()] returns, the storage is reset to its previous
+      value. *)
 
   val create_key : unit -> 'a key
-  (** Create a new storage key, guaranteed to be distinct from any previously created key. *)
+  (** Create a new storage key, guaranteed to be distinct from any previously
+      created key. *)
 
   val get : 'a key -> 'a option
 
diff --git a/src/atomic/atomic.post412.mli b/src/atomic/atomic.post412.mli
index 806271b2..7058f56d 100644
--- a/src/atomic/atomic.post412.mli
+++ b/src/atomic/atomic.post412.mli
@@ -15,8 +15,7 @@
 (*                                                                        *)
 (**************************************************************************)
 
-(** Atomic references.
-*)
+(** Atomic references. *)
 
 type 'a t = 'a Stdlib.Atomic.t
 (** An atomic (mutable) reference to a value of type ['a]. *)
@@ -34,15 +33,14 @@ val exchange : 'a t -> 'a -> 'a
 (** Set a new value for the atomic reference, and return the current value. *)
 
 val compare_and_set : 'a t -> 'a -> 'a -> bool
-(** [compare_and_set r seen v] sets the new value of [r] to [v] only
-    if its current value is physically equal to [seen] -- the
-    comparison and the set occur atomically. Returns [true] if the
-    comparison succeeded (so the set happened) and [false]
-    otherwise. *)
+(** [compare_and_set r seen v] sets the new value of [r] to [v] only if its
+    current value is physically equal to [seen] -- the comparison and the set
+    occur atomically. Returns [true] if the comparison succeeded (so the set
+    happened) and [false] otherwise. *)
 
 val fetch_and_add : int t -> int -> int
-(** [fetch_and_add r n] atomically increments the value of [r] by [n],
-    and returns the current value (before the increment). *)
+(** [fetch_and_add r n] atomically increments the value of [r] by [n], and
+    returns the current value (before the increment). *)
 
 val incr : int t -> unit
 (** [incr r] atomically increments the value of [r] by [1]. *)
diff --git a/src/atomic/atomic.pre412.mli b/src/atomic/atomic.pre412.mli
index f19bef29..231e6734 100644
--- a/src/atomic/atomic.pre412.mli
+++ b/src/atomic/atomic.pre412.mli
@@ -15,8 +15,7 @@
 (*                                                                        *)
 (**************************************************************************)
 
-(** Atomic references.
-*)
+(** Atomic references. *)
 
 type 'a t
 (** An atomic (mutable) reference to a value of type ['a]. *)
@@ -34,15 +33,14 @@ val exchange : 'a t -> 'a -> 'a
 (** Set a new value for the atomic reference, and return the current value. *)
 
 val compare_and_set : 'a t -> 'a -> 'a -> bool
-(** [compare_and_set r seen v] sets the new value of [r] to [v] only
-    if its current value is physically equal to [seen] -- the
-    comparison and the set occur atomically. Returns [true] if the
-    comparison succeeded (so the set happened) and [false]
-    otherwise. *)
+(** [compare_and_set r seen v] sets the new value of [r] to [v] only if its
+    current value is physically equal to [seen] -- the comparison and the set
+    occur atomically. Returns [true] if the comparison succeeded (so the set
+    happened) and [false] otherwise. *)
 
 val fetch_and_add : int t -> int -> int
-(** [fetch_and_add r n] atomically increments the value of [r] by [n],
-    and returns the current value (before the increment). *)
+(** [fetch_and_add r n] atomically increments the value of [r] by [n], and
+    returns the current value (before the increment). *)
 
 val incr : int t -> unit
 (** [incr r] atomically increments the value of [r] by [1]. *)
diff --git a/src/client-cohttp-lwt/config.mli b/src/client-cohttp-lwt/config.mli
index ecdc73f0..6312ae87 100644
--- a/src/client-cohttp-lwt/config.mli
+++ b/src/client-cohttp-lwt/config.mli
@@ -5,34 +5,30 @@ type t = private {
   url_logs: string;  (** Url to send logs *)
   headers: (string * string) list;
       (** API headers sent to the endpoint. Default is none or
-      "OTEL_EXPORTER_OTLP_HEADERS" if set. *)
+          "OTEL_EXPORTER_OTLP_HEADERS" if set. *)
   batch_traces: int option;
-      (** Batch traces? If [Some i], then this produces batches of (at most)
-      [i] items. If [None], there is no batching.
+      (** Batch traces? If [Some i], then this produces batches of (at most) [i]
+          items. If [None], there is no batching.
 
-      Note that traces and metrics are batched separately.
-      Default [Some 400].
-  *)
+          Note that traces and metrics are batched separately. Default
+          [Some 400]. *)
   batch_metrics: int option;
       (** Batch metrics? If [Some i], then this produces batches of (at most)
-      [i] items. If [None], there is no batching.
+          [i] items. If [None], there is no batching.
 
-      Note that traces and metrics are batched separately.
-      Default [None].
-  *)
+          Note that traces and metrics are batched separately. Default [None].
+      *)
   batch_logs: int option;
-      (** Batch logs? See {!batch_metrics} for details.
-      Default [Some 400] *)
+      (** Batch logs? See {!batch_metrics} for details. Default [Some 400] *)
   batch_timeout_ms: int;
       (** Number of milliseconds after which we will emit a batch, even
-      incomplete.
-      Note that the batch might take longer than that, because this is
-      only checked when a new event occurs. Default 500. *)
+          incomplete. Note that the batch might take longer than that, because
+          this is only checked when a new event occurs. Default 500. *)
 }
 (** Configuration.
 
-  To build one, use {!make} below. This might be extended with more
-  fields in the future. *)
+    To build one, use {!make} below. This might be extended with more fields in
+    the future. *)
 
 val make :
   ?debug:bool ->
@@ -49,28 +45,34 @@ val make :
   t
 (** Make a configuration.
 
-   @param thread if true and [bg_threads] is not provided, we will pick a number
-   of bg threads. Otherwise the number of [bg_threads] superseeds this option.
+    @param thread
+      if true and [bg_threads] is not provided, we will pick a number of bg
+      threads. Otherwise the number of [bg_threads] superseeds this option.
 
-   @param url base url used to construct per-signal urls. Per-signal url options take precedence over this base url.
-   Default is "http://localhost:4318", or "OTEL_EXPORTER_OTLP_ENDPOINT" if set.
- 
-   Example of constructed per-signal urls with the base url http://localhost:4318
-   - Traces: http://localhost:4318/v1/traces
-   - Metrics: http://localhost:4318/v1/metrics
-   - Logs: http://localhost:4318/v1/logs
- 
-   Use per-signal url options if different urls are needed for each signal type.
- 
-   @param url_traces url to send traces, or "OTEL_EXPORTER_OTLP_TRACES_ENDPOINT" if set.
-   The url is used as-is without any modification.
- 
-   @param url_metrics url to send metrics, or "OTEL_EXPORTER_OTLP_METRICS_ENDPOINT" if set.
-   The url is used as-is without any modification.
- 
-   @param url_logs url to send logs, or "OTEL_EXPORTER_OTLP_LOGS_ENDPOINT" if set.
-   The url is used as-is without any modification.
+    @param url
+      base url used to construct per-signal urls. Per-signal url options take
+      precedence over this base url. Default is "http://localhost:4318", or
+      "OTEL_EXPORTER_OTLP_ENDPOINT" if set.
 
- *)
+    Example of constructed per-signal urls with the base url
+    http://localhost:4318
+    - Traces: http://localhost:4318/v1/traces
+    - Metrics: http://localhost:4318/v1/metrics
+    - Logs: http://localhost:4318/v1/logs
+
+    Use per-signal url options if different urls are needed for each signal
+    type.
+
+    @param url_traces
+      url to send traces, or "OTEL_EXPORTER_OTLP_TRACES_ENDPOINT" if set. The
+      url is used as-is without any modification.
+
+    @param url_metrics
+      url to send metrics, or "OTEL_EXPORTER_OTLP_METRICS_ENDPOINT" if set. The
+      url is used as-is without any modification.
+
+    @param url_logs
+      url to send logs, or "OTEL_EXPORTER_OTLP_LOGS_ENDPOINT" if set. The url is
+      used as-is without any modification. *)
 
 val pp : Format.formatter -> t -> unit
diff --git a/src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.mli b/src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.mli
index ba45e3cc..675dbd52 100644
--- a/src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.mli
+++ b/src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.mli
@@ -19,8 +19,7 @@ val create_backend :
   (module Opentelemetry.Collector.BACKEND)
 (** Create a new backend using lwt and cohttp
 
-  NOTE [after_cleanup] optional parameter removed since NEXT_RELEASE
-*)
+    NOTE [after_cleanup] optional parameter removed since NEXT_RELEASE *)
 
 val setup :
   ?stop:bool Atomic.t -> ?config:Config.t -> ?enable:bool -> unit -> unit
diff --git a/src/client-ocurl/b_queue.mli b/src/client-ocurl/b_queue.mli
index 73bf3edc..d020dfb3 100644
--- a/src/client-ocurl/b_queue.mli
+++ b/src/client-ocurl/b_queue.mli
@@ -12,12 +12,12 @@ val push : 'a t -> 'a -> unit
 
 val pop : 'a t -> 'a
 (** [pop q] pops the next element in [q]. It might block until an element comes.
-   @raise Closed if the queue was closed before a new element was available. *)
+    @raise Closed if the queue was closed before a new element was available. *)
 
 val pop_all : 'a t -> 'a Queue.t -> unit
-(** [pop_all q into] pops all the elements of [q]
-  and moves them into [into]. It might block until an element comes.
-   @raise Closed if the queue was closed before a new element was available. *)
+(** [pop_all q into] pops all the elements of [q] and moves them into [into]. It
+    might block until an element comes.
+    @raise Closed if the queue was closed before a new element was available. *)
 
 val close : _ t -> unit
 (** Close the queue, meaning there won't be any more [push] allowed. *)
diff --git a/src/client-ocurl/config.mli b/src/client-ocurl/config.mli
index 7d2a5514..dda875b1 100644
--- a/src/client-ocurl/config.mli
+++ b/src/client-ocurl/config.mli
@@ -7,34 +7,32 @@ type t = private {
   url_logs: string;  (** Url to send logs *)
   headers: (string * string) list;
       (** API headers sent to the endpoint. Default is none or
-      "OTEL_EXPORTER_OTLP_HEADERS" if set. *)
+          "OTEL_EXPORTER_OTLP_HEADERS" if set. *)
   batch_timeout_ms: int;
       (** Number of milliseconds after which we will emit a batch, even
-      incomplete.
-      Note that the batch might take longer than that, because this is
-      only checked when a new event occurs or when a tick
-      is emitted. Default 2_000. *)
+          incomplete. Note that the batch might take longer than that, because
+          this is only checked when a new event occurs or when a tick is
+          emitted. Default 2_000. *)
   bg_threads: int;
-      (** Are there background threads, and how many? Default [4].
-            This will be adjusted to be at least [1] and at most [32]. *)
+      (** Are there background threads, and how many? Default [4]. This will be
+          adjusted to be at least [1] and at most [32]. *)
   ticker_thread: bool;
-      (** If true, start a thread that regularly checks if signals should
-          be sent to the collector. Default [true] *)
+      (** If true, start a thread that regularly checks if signals should be
+          sent to the collector. Default [true] *)
   ticker_interval_ms: int;
-      (** Interval for ticker thread, in milliseconds. This is
-          only useful if [ticker_thread] is [true].
-          This will be clamped between [2 ms] and some longer
-          interval (maximum [60s] currently).
-      Default 500.
-      @since 0.7 *)
+      (** Interval for ticker thread, in milliseconds. This is only useful if
+          [ticker_thread] is [true]. This will be clamped between [2 ms] and
+          some longer interval (maximum [60s] currently). Default 500.
+          @since 0.7 *)
   self_trace: bool;
-      (** If true, the OTEL library will also emit its own spans. Default [false].
+      (** If true, the OTEL library will also emit its own spans. Default
+          [false].
           @since 0.7 *)
 }
 (** Configuration.
 
-  To build one, use {!make} below. This might be extended with more
-  fields in the future. *)
+    To build one, use {!make} below. This might be extended with more fields in
+    the future. *)
 
 val make :
   ?debug:bool ->
@@ -52,24 +50,30 @@ val make :
   t
 (** Make a configuration.
 
-    @param url base url used to construct per-signal urls. Per-signal url options take precedence over this base url.
-    Default is "http://localhost:4318", or "OTEL_EXPORTER_OTLP_ENDPOINT" if set.
+    @param url
+      base url used to construct per-signal urls. Per-signal url options take
+      precedence over this base url. Default is "http://localhost:4318", or
+      "OTEL_EXPORTER_OTLP_ENDPOINT" if set.
 
-    Example of constructed per-signal urls with the base url http://localhost:4318
+    Example of constructed per-signal urls with the base url
+    http://localhost:4318
     - Traces: http://localhost:4318/v1/traces
     - Metrics: http://localhost:4318/v1/metrics
     - Logs: http://localhost:4318/v1/logs
 
-    Use per-signal url options if different urls are needed for each signal type.
+    Use per-signal url options if different urls are needed for each signal
+    type.
 
-    @param url_traces url to send traces, or "OTEL_EXPORTER_OTLP_TRACES_ENDPOINT" if set.
-    The url is used as-is without any modification.
+    @param url_traces
+      url to send traces, or "OTEL_EXPORTER_OTLP_TRACES_ENDPOINT" if set. The
+      url is used as-is without any modification.
 
-    @param url_metrics url to send metrics, or "OTEL_EXPORTER_OTLP_METRICS_ENDPOINT" if set.
-    The url is used as-is without any modification.
+    @param url_metrics
+      url to send metrics, or "OTEL_EXPORTER_OTLP_METRICS_ENDPOINT" if set. The
+      url is used as-is without any modification.
 
-    @param url_logs url to send logs, or "OTEL_EXPORTER_OTLP_LOGS_ENDPOINT" if set.
-    The url is used as-is without any modification.
- *)
+    @param url_logs
+      url to send logs, or "OTEL_EXPORTER_OTLP_LOGS_ENDPOINT" if set. The url is
+      used as-is without any modification. *)
 
 val pp : Format.formatter -> t -> unit
diff --git a/src/core/lock.mli b/src/core/lock.mli
index 1b6c8c4b..6ef1946e 100644
--- a/src/core/lock.mli
+++ b/src/core/lock.mli
@@ -1,7 +1,7 @@
 val set_mutex : lock:(unit -> unit) -> unlock:(unit -> unit) -> unit
-(** Set a pair of lock/unlock functions that are used to
-    protect access to global state, if needed. By default these do nothing. *)
+(** Set a pair of lock/unlock functions that are used to protect access to
+    global state, if needed. By default these do nothing. *)
 
 val with_lock : (unit -> 'a) -> 'a
-(** Call [f()] while holding the mutex defined {!set_mutex}, then
-    release the mutex. *)
+(** Call [f()] while holding the mutex defined {!set_mutex}, then release the
+    mutex. *)
diff --git a/src/core/rand_bytes.mli b/src/core/rand_bytes.mli
index bea76349..7c42ea35 100644
--- a/src/core/rand_bytes.mli
+++ b/src/core/rand_bytes.mli
@@ -3,12 +3,12 @@
     We need random identifiers for trace IDs and span IDs. *)
 
 val rand_bytes_16 : (unit -> bytes) ref
-(** Generate 16 bytes of random data.
-   The implementation can be swapped to use any random generator. *)
+(** Generate 16 bytes of random data. The implementation can be swapped to use
+    any random generator. *)
 
 val rand_bytes_8 : (unit -> bytes) ref
-(** Generate 16 bytes of random data.
-   The implementation can be swapped to use any random generator. *)
+(** Generate 16 bytes of random data. The implementation can be swapped to use
+    any random generator. *)
 
 val default_rand_bytes_8 : unit -> bytes
 (** Default implementation using {!Random} *)
diff --git a/src/integrations/cohttp/opentelemetry_cohttp_lwt.ml b/src/integrations/cohttp/opentelemetry_cohttp_lwt.ml
index 12661022..fd2ff1a4 100644
--- a/src/integrations/cohttp/opentelemetry_cohttp_lwt.ml
+++ b/src/integrations/cohttp/opentelemetry_cohttp_lwt.ml
@@ -17,17 +17,15 @@ module Server : sig
       Use it like this:
 
       {[
-      let my_server callback =
-        let callback_traced =
-          Opentelemetry_cohttp_lwt.Server.trace
-            ~service_name:"my-service"
-            (fun _scope -> callback)
-        in
-        Cohttp_lwt_unix.Server.create
-          ~mode:(`TCP (`Port 8080))
-          (Server.make () ~callback:callback_traced)
-      ]}
-   *)
+        let my_server callback =
+          let callback_traced =
+            Opentelemetry_cohttp_lwt.Server.trace ~service_name:"my-service"
+              (fun _scope -> callback)
+          in
+          Cohttp_lwt_unix.Server.create
+            ~mode:(`TCP (`Port 8080))
+            (Server.make () ~callback:callback_traced)
+      ]} *)
 
   val with_ :
     ?trace_state:string ->
@@ -43,24 +41,20 @@ module Server : sig
 
       Identical to [Opentelemetry_lwt.Trace.with_], but fetches/stores the trace
       scope in the [x-ocaml-otel-traceparent] header in the request for
-      convenience.
-   *)
+      convenience. *)
 
   val get_trace_context :
     ?from:[ `Internal | `External ] -> Request.t -> Otel.Scope.t option
   (** Get the tracing scope from the custom [x-ocaml-otel-traceparent] header
-      added by [trace] and [with_].
-   *)
+      added by [trace] and [with_]. *)
 
   val set_trace_context : Otel.Scope.t -> Request.t -> Request.t
   (** Set the tracing scope in the custom [x-ocaml-otel-traceparent] header used
-      by [trace] and [with_].
-   *)
+      by [trace] and [with_]. *)
 
   val remove_trace_context : Request.t -> Request.t
   (** Strip the custom [x-ocaml-otel-traceparent] header added by [trace] and
-      [with_].
-   *)
+      [with_]. *)
 end = struct
   let attrs_of_request (req : Request.t) =
     let meth = req |> Request.meth |> Code.string_of_method in
diff --git a/src/lwt/opentelemetry_lwt.ml b/src/lwt/opentelemetry_lwt.ml
index e6d53ed8..7b443c20 100644
--- a/src/lwt/opentelemetry_lwt.ml
+++ b/src/lwt/opentelemetry_lwt.ml
@@ -12,8 +12,8 @@ module Metrics_callbacks = Metrics_callbacks
 module Trace_context = Trace_context
 
 external reraise : exn -> 'a = "%reraise"
-(** This is equivalent to [Lwt.reraise]. We inline it here so we don't force
-    to use Lwt's latest version *)
+(** This is equivalent to [Lwt.reraise]. We inline it here so we don't force to
+    use Lwt's latest version *)
 
 module Trace = struct
   include Trace
diff --git a/src/trace/opentelemetry_trace.ml b/src/trace/opentelemetry_trace.ml
index dd423d84..0126257b 100644
--- a/src/trace/opentelemetry_trace.ml
+++ b/src/trace/opentelemetry_trace.ml
@@ -144,8 +144,8 @@ module Internal = struct
     assert (Bytes.length bs = 8);
     Bytes.get_int64_le bs 0
 
-  let enter_span' ?(explicit_parent : Otrace.explicit_span_ctx option) ~__FUNCTION__ ~__FILE__ ~__LINE__ ~data name
-      =
+  let enter_span' ?(explicit_parent : Otrace.explicit_span_ctx option)
+      ~__FUNCTION__ ~__FILE__ ~__LINE__ ~data name =
     let open Otel in
     let otel_id = Span_id.create () in
     let otrace_id = otrace_of_otel otel_id in
@@ -159,7 +159,8 @@ module Internal = struct
     let parent =
       match explicit_parent, parent_scope with
       | Some p, _ ->
-        Some (Otel.Span_ctx.make ~trace_id ~parent_id:(span_id_to_otel p.span) ())
+        Some
+          (Otel.Span_ctx.make ~trace_id ~parent_id:(span_id_to_otel p.span) ())
       | None, Some parent -> Some (Otel.Scope.to_span_ctx parent)
       | None, None -> None
     in