jddlZddlZddlmZmZmZmZddlmZm Z GddZ e Z e jZ e jZ e jZe jZe j Ze j"Ze j$Ze j&Ze j(Ze j*Zde fdZej.dej0d ee j2ded fd Zy) N)ListOptional GeneratorTuple)spantracecbeZdZdZddZdedefdZdeddfdZde e jfdZ dd e ede e jfd Z d e jddfd Zdefd ZdefdZde ej&fdZ dd e ede ej&fdZde ej&ddfdZddZddZy)OpikContextStoragea Manages span and trace context using Python's contextvars. ## IMPORTANT: Working with ContextVars This class uses ContextVars to maintain isolated stacks across different execution contexts (like threads or async tasks). To ensure proper isolation and safety, this implementation uses immutable tuples for stack storage. ### DO use immutable data structures and create-new-set pattern: For adding elements: ```python # Get current tuple and create a new one with added element stack = spans_stack_context.get() spans_stack_context.set(stack + (new_element,)) ``` For removing elements: ```python # Get current tuple and create a new one without the last element stack = spans_stack_context.get() spans_stack_context.set(stack[:-1]) ``` The methods in this class follow these patterns and provide a safe API for manipulating the context stacks. returnNctjdd|_t}tjd||_y)Ncurrent_trace_data)defaultspans_data_stack) contextvars ContextVar_current_trace_data_contexttuple_spans_data_stack_context)selfdefault_span_stacks m/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/context_storage.py__init__zOpikContextStorage.__init__&sC  " "#7 F (9>  " "#5?Q R &span_idc\tfd|jjDS)Nc3<K|]}|jk(ywN)id).0rrs r z2OpikContextStorage._has_span_id..0sW2V$477g%2Vs)anyrget)rrs `r _has_span_idzOpikContextStorage._has_span_id/s#W$2P2P2T2T2VWWWrc|j|sy|jj}g}|D]$}|j||j|k(s$n|jj t |y)a\ If span with the given id exists in the stack, eliminates the spans from the stack until the span with the given id is at the top. Intended to be used in the modules that perform unsafe manipulations with the span data stack (when there is a risk of missing the pop operation, e.g. in callback-based integrations). When the id of the span that SHOULD be on top is known, we can trim the stack to remove hanged spans if there are any. Args: span_id: The id of the span to trim the stack to. Returns: None N)r#rr"appendrsetr)rrstacknew_stack_list span_datas r$trim_span_data_stack_to_certain_spanz7OpikContextStorage.trim_span_data_stack_to_certain_span2sp   ) ..224.0I  ! !) ,||w& &&**5+@Arcb|jry|jj}|dS)N)span_data_stack_emptyrr")rr's r top_span_dataz OpikContextStorage.top_span_dataNs/  % % '..224Ryr ensure_idc|jry|=|jj}|jj|dd|dS|j j |k(r|j Sd}|S)a Pops the span from the stack. Args: ensure_id: If provided, it will pop the span only if it has the given id. Intended to be used in the modules that perform unsafe manipulations with the span data stack (when there is a risk of missing the add or pop operation, e.g. in callback-based integrations), to make sure the correct span is popped. Returns: The span that was popped from the stack or None. Nr,)r-rr"r&r.r pop_span_data)rr/r''STACK_IS_EMPTY_OR_THE_ID_DOES_NOT_MATCHs rr1z OpikContextStorage.pop_span_dataTs  % % '  22668E  * * . .uSbz :9      " "i /%%' '26/66rrcv|jj}|jj||fzyr)rr"r&)rrr's r add_span_dataz OpikContextStorage.add_span_dataps0..224 &&**5D7?;rcNt|jjdk(S)Nrlenrr"rs rr-z(OpikContextStorage.span_data_stack_emptyts!4115578A==rcHt|jjSrr6r8s rspan_data_stack_sizez'OpikContextStorage.span_data_stack_sizews41155788rc:|jj}|Sr)rr")r trace_datas rget_trace_dataz!OpikContextStorage.get_trace_datazs5599; rc|jj}|y||j|k7ry|jd|S)a Pops the trace from the context. Args: ensure_id: If provided, it will pop the trace only if it has the given id. Intended to be used in the modules that perform unsafe manipulations with the trace data (when there is a risk of missing the set operation, e.g. in callback-based integrations), to make sure the correct trace is popped. Returns: The trace that was popped from the context or None. N)rr"rset_trace_data)rr/r<s rpop_trace_dataz!OpikContextStorage.pop_trace_data~sI5599;    Z]]i%? D!rrc:|jj|yr)rr&)rrs rr?z!OpikContextStorage.set_trace_datas ((,,U3rcJ|jjtyr)rr&rr8s r clear_spanszOpikContextStorage.clear_spanss &&**573rcZ|jjd|jyr)rr&rCr8s r clear_allzOpikContextStorage.clear_alls" ((,,T2 r)r Nr)__name__ __module__ __qualname____doc__rstrboolr#r*rrSpanDatar.r1r4r-intr:r TraceDatar=r@r?rCrErrr r s:SXCXDXBCBDB8x 6$(7C=7 $-- 78<$--t>9c9 9 *.!# %// "04HU__$=4$44rr r ctSr)_context_storagerOrrget_current_context_instancerRs rr)r<)NNNc#K t}| t|t|dt|ty#ttwxYww)z Temporarily adds span and trace data to the context. If trace_data is None, it has no effect on the current trace in the context. N)r)r=r?r4r1)r)r<original_traces rtemporary_contextrUsI ')  !  ,i  ~& ~&sA'AAAA)r contextlibtypingrrrropik.api_objectsrrr rQr.r1r4r-r=r@r?rEr:r*rRcontextmanagerrLrNrUrOrrrZs33(VVr&' ..  ..  .. (>>!00!00!00  & & '<<99% &8 }}*25??*C r