+ nDj2Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t H t H t ]P!]4t] !R]R] 3,R7t0RmtRR ltR sR sR R ltR RltRRltRRltRRlt]P6RRl4tRRltR#)u OpenTelemetry tracing helpers shared across Rerun-based Python code. Provides [`with_tracing`][rerun._tracing.with_tracing] (decorator) and [`tracing_scope`][rerun._tracing.tracing_scope] (context manager), which both create a Python OpenTelemetry span and bridge the trace context into Rerun's Rust SDK so `#[instrument]` spans on the Rust side become children of the Python span. Active only when `TELEMETRY_ENABLED=true` is set in the environment AND an OTLP endpoint is configured via `OTEL_EXPORTER_OTLP_TRACES_ENDPOINT` (or the umbrella `OTEL_EXPORTER_OTLP_ENDPOINT`). Otherwise both helpers are pass-throughs. This module is private — external callers should re-export these helpers from the consumer package rather than importing `rerun._tracing` directly. ) annotationsN)CallableIterator)AnyTypeVarcastF.)boundc V^8dQhRRRR/#)namestrreturnbool)formats"R/data/cameron/venvs/s3viz/lib/python3.14/site-packages/rerun_sdk/rerun/_tracing.py __annotate__r"s;;C;D;c~\PPV4;'gRP4\9#))osenvirongetlower_TRUTHY)r s&r _env_boolr"s+ JJNN4 & &B - - /7 ::rFcV^8dQhRR/#)r rNoner)rs"rrr*s"j"jD"jrc\'dR#Rs\R4'gR#^RIHp^RIHp^RIHp^RIH p^RI H p\P P#R 4;'g \P P#R 4pT'g\P%R 4R#\P P#R 4;'gRpT!TP'RT/4R7pTP)T!T!TR744TP+T4Rs\P%RYe4R# \d\PR 4R#i;i)zCSet up the Python OTel tracer provider the first time it is needed.NTTELEMETRY_ENABLEDtrace)OTLPSpanExporter)Resource)TracerProvider)BatchSpanProcessorzU`with_tracing` is a no-op: install OpenTelemetry via `pip install rerun-sdk[tracing]`"OTEL_EXPORTER_OTLP_TRACES_ENDPOINTOTEL_EXPORTER_OTLP_ENDPOINTzj`with_tracing` is a no-op: set OTEL_EXPORTER_OTLP_TRACES_ENDPOINT or OTEL_EXPORTER_OTLP_ENDPOINT to enableOTEL_SERVICE_NAMEzrerun-pyz service.name)resource)endpointz>Python OpenTelemetry tracing enabled (service=%s, endpoint=%s)) _initializedr opentelemetryr"5opentelemetry.exporter.otlp.proto.grpc.trace_exporterr#opentelemetry.sdk.resourcesr$opentelemetry.sdk.tracer%opentelemetry.sdk.trace.exportr& ImportErrorloggerwarningrrrinfocreateadd_span_processorset_tracer_provider_enabled)r"r#r$r%r&r+ service_nameproviders r _init_oncer<*s|L ( ) )'Z8:E zz~~BCttrzz~~VsGtH  x  ::>>"56DD*Lx 7U'VWH  23CX3V WX h'H KKPR^i% nosD44 EEcV^8dQhRR/#)r rdict[str, str] | Noner)rs"rrrOs4rc\4\'gR#^RIHp^RIHp/pV!4P W P44T;'gR#)aF Capture the current OTel context as a W3C carrier dict. Returns `None` if tracing is disabled or no context is active. The carrier is safe to pickle and pass across process boundaries; pair with [`attach_parent_carrier`][rerun._tracing.attach_parent_carrier] in the child to make its spans children of the captured context. Ncontextget_global_textmap)r<r9r-rAopentelemetry.propagaterCinject get_current)rArCcarriers rcurrent_trace_carrierrHOsBL 8%: G)<)<)>? ??drc V^8dQhRRRR/#)r rGr>rrr)rs"rrrds::#8:T:rcV'gR#\4\'gR#^RIHp^RIHpVP V!4PV44R#)u Attach a W3C carrier as the ambient parent context for the current thread. All subsequent spans created on this thread (via [`with_tracing`][rerun._tracing.with_tracing] or otherwise) will be parented under the extracted context. The attachment is intentionally not detached — call this once per worker thread/process on entry, typically from `__setstate__` after unpickling. No-op when `carrier` is `None` or tracing is disabled. Nr@rB)r<r9r-rArDrCattachextract)rGrArCs& rattach_parent_carrierrMds8 L 8%: NN%'//89rcV^8dQhRR/#)r rtuple[Any, Any] | Noner)rs"rrr{s--5-rcl^RIHpV!4pVfR#\4pVfR#WPV43#)z Write the current OTel context into Rerun's `ContextVar` so Rust can read it. Returns `(context_var, token)` to pass to [`_pop_carrier_from_rust`][], or `None` if Rust was built without `perf_telemetry` or no OTel context is active. )_get_trace_context_varN)rerun_bindingsrQrHset)rQ trace_ctxrGs r_push_carrier_to_rustrU{s:6&(I#%G mmG, ,,rc V^8dQhRRRR/#)r attachmentrOrrr)rs"rrrs'=$rc<VfR#VwrVPV4R#N)reset)rWrTtokens& r_pop_carrier_from_rustr\s!I OOErc V^8dQhRRRR/#)r r r rzIterator[None]r)rs"rrrs!/!/!/!/rc#2"\4\'gRxR#^RIHpVP R4P V4;_uu_4\ 4pRx\V4RRR4R# \T4i;i +'giR#;i5i)u Open an OpenTelemetry span for the duration of a `with` block and propagate trace context into Rerun's Rust SDK. Context-manager counterpart to [`with_tracing`][rerun._tracing.with_tracing] — use it to scope arbitrary blocks of code without extracting them into a function. Any Rust-side `#[instrument]` spans triggered from within will be parented under this span in Jaeger. No-op unless `TELEMETRY_ENABLED=true` and an OTLP endpoint is configured (`OTEL_EXPORTER_OTLP_TRACES_ENDPOINT` or `OTEL_EXPORTER_OTLP_ENDPOINT`). Examples -------- ```python for epoch in range(num_epochs): with tracing_scope(f"epoch {epoch}"): train_one_epoch(...) ``` Nr!rerun)r<r9r-r" get_tracerstart_as_current_spanrUr\)r r"rWs& r tracing_scoperbsm,L 8 #   ' " 8 8 > >*,  /  ": . ? > #: . ? > >s6A B BA3 B) B3 BB B  Bc V^8dQhRRRR/#)r r r rzCallable[[F], F]r)rs"rrrss/rcaRV3RllpV#)az Wrap a function in an OpenTelemetry span and propagate trace context into Rerun's Rust SDK. When enabled, creates a span named `name`, injects the W3C `traceparent` header into Rerun's shared `ContextVar`, and runs the wrapped function. Any Rust-side `#[instrument]` spans triggered from within (e.g. catalog queries) will be parented under this span in Jaeger. For ad-hoc blocks that don't belong in a dedicated function, use [`tracing_scope`][rerun._tracing.tracing_scope] instead. No-op unless `TELEMETRY_ENABLED=true` and an OTLP endpoint is configured (`OTEL_EXPORTER_OTLP_TRACES_ENDPOINT` or `OTEL_EXPORTER_OTLP_ENDPOINT`). c V^8dQhRRRR/#)r funcrrr)rs"rr"with_tracing..__annotate__s"""a"rcd<a\P!S4RVV3Rll4p\RV4#)c$V^8dQhRRRRRR/#)r argsrkwargsrr)rs"rr5with_tracing..decorator..__annotate__s! - -3 -# -# -rcx<\S4;_uu_4S!V/VBuuRRR4# +'giR#;irY)rb)rjrkrfr s*,rwrapper0with_tracing..decorator..wrappers*t$$T,V,%$$$s( 9 r) functoolswrapsr)rfrnr sf r decoratorwith_tracing..decorators2   - -  -C!!rr)r rrsf r with_tracingrts "" r>1onyestrue)__doc__ __future__r contextlibrploggingrcollections.abcrrtypingrrr getLogger__name__r3rrrr,r9r<rHrMrUr\contextmanagerrbrtrrrrs"# .%%   8 $ CxS)* $; "jJ*:.-( !/!/Hr