o i@sVddlmZddlZddlmZddlmZddZdeeeeeffdd Z dS) )OptionalN)core)ContextcCsntj}tddjj}|d}d|vr!|d}|dd}n |d|dd}}||t||f|||S)z Wrap `Executor` method used to submit a work executed in another thread. This wrapper ensures that a new `Context` is created and properly propagated using an intermediate function. zthreading.submitrfnN) ddtracetracercurrent_trace_contextrdispatch_with_results llmobs_ctxvaluepop_wrap_execution)funcargskwargs current_ctxr selfrfn_argsrr^/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/internal/futures/threading.py _wrap_submits  rctxcCsv|ddurtd|df|ddur4tj|d||i|WdS1s/wY||i|S)aE Intermediate target function that is executed in a new thread; it receives the original function with arguments and keyword arguments, including our tracing `Context`. The current context provider sets the Active context in a thread local storage variable because it's outside the asynchronous loop. rNzthreading.executionr)rdispatchr r _activate_context)rrrrrrrrs    r) typingrr ddtrace.internalr ddtrace.tracerrtuplerrrrrs   "