]jPSSKJr SSKrSSKJr SSKJrJr SSKJ r J r SSK J r J r Jr SSKJr SS KJrJr \R(q\R(qSS jr\"[*5SS j5r\"[,5SS j5rSS jrSSjrSSjrg!\a SSjrNf=f)) annotationsN)asdict)partialwraps)AnyCallable)ContextCarrierattach_context get_context)warn_at_user_stacklevel)ProcessPoolExecutorThreadPoolExecutorc[R[La[[l[R[ La[ [lgg)zMonkey-patch `submit()` methods of `ThreadPoolExecutor` and `ProcessPoolExecutor` to carry over OTEL context across threads and processes. N)rsubmit submit_t_origsubmit_tr submit_p_origsubmit_pe/home/mande/repo/quber/.venv/lib/python3.13/site-packages/logfire/_internal/integrations/executors.pyinstrument_executorsrs7  $ $ 5(0  %  % % 6)1  & 7rcT[U/UQ70UD6n[5n[U[XASS9$)z[A wrapper around ThreadPoolExecutor.submit() that carries over OTEL context across threads.Ncarrierfunc parent_config)rr r_run_with_contextsfnargskwargsrs rrrs2R )$ )& )-Q 17[_``rcd[U/UQ70UD6n[5n[U[XA[ 5S9$)z^A wrapper around ProcessPoolExecutor.submit() that carries over OTEL context across processes.r)rr rrserialize_configr s rrr%s5R )$ )& )-Q 17[k[mnnrcxUb [U5 [U5 U"5sSSS5 $!,(df  g=f)zA wrapper around a function that restores OTEL context from a carrier and then calls the function. This gets run from within a process / thread. N)deserialize_configr rs rrr,s+  $ } - G $6% $ $s+ 9cg)Nrrrrrr;s rcSSKJn [U5n[R"U5 U$![ a [ S[5 gf=f)zSerialize the global config for transmission to child processes. Returns None if the config cannot be pickled, in which case a warning is emitted. See: https://github.com/pydantic/logfire/issues/1556 r ) GLOBAL_CONFIGaThe Logfire configuration cannot be pickled and will not be automatically sent to child processes. You will need to manually call logfire.configure() in each child process. This typically happens when using local functions as callbacks (e.g., exception_callback).N)configr+rpickledumps Exceptionr UserWarning)r+ config_dicts rr&r&?sP ']+  [!  7   s"+AAcPSSKJnJn UcgUR(d U"S0UD6 gg)zrAs" $ II00 K&--M'..M2 =aa  =oo  '8 I^   &6C   sAB B%$B%