Cj5SSKJr SSKrSSKrSSKrSSKrSSKJrJr SSK J r J r SSK J r SSK J r SS KJr SS KJr SS KJr SS KJrJrJrJr SS KJrJrJr SSjr"SS\5r"SS\5r"SS\5r g)) annotationsN)ABCabstractmethod)datetimetimezone)Any)logger) TracingConfig)TracingProcessor)Scope)NoOpSpanSpanSpanImpl TSpanData) NoOpTraceTrace TraceImplcSSjnU"[5(ag[R"U5 g![a gf=f)zHBest-effort debug logging that tolerates closed streams during shutdown.cUnUb]URH)n[USS5nUcM[USS5(dM) g UR(dgURnUbM]g)NstreamclosedFT)handlersgetattr propagateparent)logcurrenthandlerrs i/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/agents/tracing/provider.py_has_closed_stream_handler/_safe_debug.._has_closed_stream_handlersk),!"++ (D9%'&(E*J*J,$$nnG!N)rzlogging.Loggerreturnbool)r debug Exception)messager"s r! _safe_debugr*s8  %f - -  W s00 ==cj\rSrSrSrSrSSjrSSjrSSjrSSjr SSjr SS jr SS jr S r S rg ) SynchronousMultiTracingProcessor,zN Forwards all calls to a list of TracingProcessors, in order of registration. cFSUl[R"5Ulg)N) _processors threadingLock_lockselfs r!__init__)SynchronousMultiTracingProcessor.__init__1s9;^^% r$c|UR U=RU4- slSSS5 g!,(df  g=fzZ Add a processor to the list of processors. Each processor will receive all traces/spans. Nr3r0)r5tracing_processors r!add_tracing_processor6SynchronousMultiTracingProcessor.add_tracing_processor6s*ZZ   !2 4 4 ZZs- ;cpUR [U5UlSSS5 g!,(df  g=fzO Set the list of processors. This will replace the current list of processors. N)r3tupler0r5 processorss r!set_processors/SynchronousMultiTracingProcessor.set_processors=s"ZZ$Z0D ZZs' 5cURHnURU5 M g![a'n[R"SUSU35 SnAMFSnAff=f)z! Called when a trace is started. Error in trace processor z during on_trace_start: N)r0on_trace_startr(r errorr5trace processores r!rG/SynchronousMultiTracingProcessor.on_trace_startDs\))I a((/* a 8 C[\][^_`` a' AAAcURHnURU5 M g![a'n[R"SUSU35 SnAMFSnAff=f)z" Called when a trace is finished. rFz during on_trace_end: N)r0 on_trace_endr(r rHrIs r!rP-SynchronousMultiTracingProcessor.on_trace_endNs\))I _&&u-* _ 8 CYZ[Y\]^^ _rNcURHnURU5 M g![a'n[R"SUSU35 SnAMFSnAff=f)z Called when a span is started. rFz during on_span_start: N)r0 on_span_startr(r rHr5spanrKrLs r!rS.SynchronousMultiTracingProcessor.on_span_startXs\))I `''-* ` 8 CZ[\Z]^__ `rNcURHnURU5 M g![a'n[R"SUSU35 SnAMFSnAff=f)z! Called when a span is finished. rFz during on_span_end: N)r0 on_span_endr(r rHrTs r!rX,SynchronousMultiTracingProcessor.on_span_endbs\))I ^%%d+* ^ 8 CXYZX[\]] ^rNcURH"n[SU35 UR5 M$ g![a'n[R "SUSU35 SnAMSSnAff=f)z$ Called when the application stops. zShutting down trace processor z$Error shutting down trace processor : N)r0r*shutdownr(r rHr5rKrLs r!r\)SynchronousMultiTracingProcessor.shutdownlsi))I 8 D E V""$* V CI;bQRPSTUU Vs4 A%A  A%cURHnUR5 M g![a'n[R"SUSU35 SnAMESnAff=f)z. Force the processors to flush their buffers. zError flushing trace processor r[N)r0 force_flushr(r rHr]s r!r`,SynchronousMultiTracingProcessor.force_flushwsW))I Q%%'* Q >ykA3OPP Qs& AAAr:N)r;r rBlist[TracingProcessor])rJrr%None)rUz Span[Any]r%rdr%rd)__name__ __module__ __qualname____firstlineno____doc__r6r<rCrGrPrSrXr\r`__static_attributes__r/r$r!r,r,,s:& 51a_`^ VQr$r,cL\rSrSrSr\SSj5r\SSj5r\SSj5r\SSj5r \SSj5r \SSj5r \SS j5r \SS j5r \SS j5r\SSS jj5r\SSSjj5rSSjrSSjrSrg ) TraceProviderz(Interface for creating traces and spans.cg)z7Add a processor that will receive all traces and spans.Nr/r5rKs r!register_processor TraceProvider.register_processorr$cg)z3Replace the list of processors with ``processors``.Nr/rAs r!rCTraceProvider.set_processorsrsr$cg)z*Return the currently active trace, if any.Nr/r4s r!get_current_traceTraceProvider.get_current_tracersr$cg)z)Return the currently active span, if any.Nr/r4s r!get_current_spanTraceProvider.get_current_spanrsr$cg)z#Enable or disable tracing globally.Nr/r5disableds r! set_disabledTraceProvider.set_disabledrsr$cg)+Return the current time in ISO 8601 format.Nr/r4s r!time_isoTraceProvider.time_isorsr$cg)z Generate a new trace identifier.Nr/r4s r! gen_trace_idTraceProvider.gen_trace_idrsr$cg)zGenerate a new span identifier.Nr/r4s r! gen_span_idTraceProvider.gen_span_idrsr$cg)z Generate a new group identifier.Nr/r4s r! gen_group_idTraceProvider.gen_group_idrsr$Ncg)zCreate a new trace.Nr/r5nametrace_idgroup_idmetadatar~tracings r! create_traceTraceProvider.create_tracersr$cg)zCreate a new span.Nr/)r5 span_dataspan_idrr~s r! create_spanTraceProvider.create_spanrsr$cg)zForce all registered processors to flush buffered traces/spans immediately. The default implementation is a no-op so existing custom ``TraceProvider`` implementations continue to work without adding this method. Nr/r4s r!r`TraceProvider.force_flush r$cg)zClean up any resources used by the provider. The default implementation is a no-op so existing custom ``TraceProvider`` implementations continue to work without adding this method. Nr/r4s r!r\TraceProvider.shutdownrr$r/)rKr r%rd)rBrcr%rdr%z Trace | Noner%zSpan[Any] | Noner~r&r%rdr%strNNNFNrrr str | Nonerrrzdict[str, Any] | Noner~r&rzTracingConfig | Noner%rNNF rrrrrzTrace | Span[Any] | Noner~r&r%zSpan[TSpanData]re)rfrgrhrirjrrqrCrwrzrrrrrrrr`r\rkr/r$r!rmrms}2FFBB998822:://..// $#*.(, " " " " ( "  "& "  " "#+/ !!!) !  !  !!r$rmc\rSrSrSSjrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSSSjjrSSSjjrSSjrSSjrSrg )DefaultTraceProvidercL[5UlSUlSUlSUlg)NF)r,_multi_processor _env_disabled_manual_disabled _disabledr4s r!r6DefaultTraceProvider.__init__s$ @ B*.-1r$c:URRU5 gr9)rr<rps r!rq'DefaultTraceProvider.register_processors 33I>r$c:URRU5 gr?)rrCrAs r!rC#DefaultTraceProvider.set_processorss ,,Z8r$c,[R"5$)z- Returns the currently active trace, if any. )rrwr4s r!rw&DefaultTraceProvider.get_current_traces&&((r$c,[R"5$)z, Returns the currently active span, if any. )rrzr4s r!rz%DefaultTraceProvider.get_current_spans%%''r$c0XlUR5 g)z" Set whether tracing is disabled. N)r_refresh_disabled_flagr}s r!r!DefaultTraceProvider.set_disableds!) ##%r$cURc6[RRSS5R 5S;UlUR c[ UR5UlgUR Ulg)aRefresh disabled flag from cached env value and manual override. The env flag is read once on first use to avoid surprises mid-run; further env changes are ignored after the manual flag is set via set_disabled, which always takes precedence over the env value. NOPENAI_AGENTS_DISABLE_TRACINGfalse)true1)rosenvirongetlowerrr&rr4s r!r+DefaultTraceProvider._refresh_disabled_flagsh    %!#/"eg"D   (!$"4"45DN!22DNr$cf[R"[R5R 5$)r)rnowrutc isoformatr4s r!rDefaultTraceProvider.time_iso s||HLL)3355r$cFS[R"5R3$)zGenerate a new trace ID.trace_uuiduuid4hexr4s r!r!DefaultTraceProvider.gen_trace_ids (()**r$cLS[R"5RSS3$)zGenerate a new span ID.span_Nrr4s r!r DefaultTraceProvider.gen_span_ids#tzz|'',-..r$cLS[R"5RSS3$)zGenerate a new group ID.group_Nrrr4s r!r!DefaultTraceProvider.gen_group_ids# (("-.//r$Nc fUR5 UR(dU(a#[R"SU35 [ 5$U=(d UR 5n[R"SUSU35 [ UUUUURU(aURS5S9$SS9$)z Create a new trace. z(Tracing is disabled. Not creating trace zCreating trace with id api_keyN)rrrrrKtracing_api_key) rrr r'rrrrrrs r!r!DefaultTraceProvider.create_traces ##% >>X LLCD6J K; 2t002 tfIhZ@A++6=GKK 2   DH   r$c UR5 SnSnUR(dU(a$[R"SU35 [ U5$U(d[ R "5n[ R"5nUc![R"S5 [ U5$[U[5(d[U[5(a([R"SUSUS35 [ U5$U(a UROSn URn URn[USS5nO[U[5(ab[U[5(a%[R"SUS35 [ U5$URn Sn URn[USS5nO[U[ 5(aj[U[5(a%[R"SUS35 [ U5$URn URn URnUR"n[R"SUS U35 [%W U=(d UR'5W UR(UUUS 9$) z Create a new span. Nz'Tracing is disabled. Not creating span zTNo active trace. Make sure to start a trace with `trace()` first Returning NoOpSpan.zParent z or z is no-op, returning NoOpSpanrzCreating span r)rr parent_idrKrrtrace_metadata)rrr r'rrrzrwrH isinstancerrrrrrrrrrr) r5rrrr~rr current_span current_tracerrs r!r DefaultTraceProvider.create_span8s ##%&*04 >>X LLB9+N OI& & 113L!335M$ * **M955LRZ9[9[ l^4 >[\ **0< ,,$I$--H+;;O$]JEN  & &&),, wvh.KLM **HI$44O$VZ>N  % %&(++ wvh.KLM **IH$44O#22N ~i[ 'CD1t//1+++)  r$cUR5 UR(agURR5 g![a#n[ R "SU35 SnAgSnAff=f)z8Force all processors to flush their buffers immediately.NzError flushing trace provider: )rrrr`r(r rHr5rLs r!r` DefaultTraceProvider.force_flush|sY ##% >>  @  ! ! - - / @ LL:1#> ? ? @s? A, A''A,cUR5 UR(ag[S5 URR 5 g![ a#n[ R"SU35 SnAgSnAff=f)NzShutting down trace providerz$Error shutting down trace provider: )rrr*rr\r(r rHrs r!r\DefaultTraceProvider.shutdownsb ##% >>  E 6 7  ! ! * * , E LL?sC D D Es%A A7A22A7)rrrrre)rKr rbrrrrrrrr)rfrgrhrir6rqrCrwrzrrrrrrrrr`r\rkr/r$r!rrs? 9 ) ( &3&6+/0 $#*.(,     (    &   B#+/ B B B ) B  B  B H @ Er$r)r)rr%rd)! __future__rloggingrr1rabcrrrrtypingrr configr processor_interfacer scoperspansrrrrtracesrrrr*r,rmrr/r$r!rsk"  #'!166//2SQ'7SQlKCK\@E=@Er$