temporalio.contrib.opentelemetry._otel_interceptor

module documentation
(source)

OpenTelemetry interceptor that creates/propagates spans.

Variable default_text_map_propagator Default text map propagator used by TracingInterceptor.
Class _InputWithHeaders Undocumented
Class _TracingActivityInboundInterceptor Undocumented
Class _TracingClientOutboundInterceptor Undocumented
Class _TracingNexusOperationInboundInterceptor Undocumented
Class _TracingWorkflowInboundInterceptor Tracing interceptor for workflow calls.
Class _TracingWorkflowOutboundInterceptor Undocumented
Function _context_to_headers Undocumented
Function _context_to_nexus_headers Undocumented
Function _headers_to_context Undocumented
Function _maybe_span Undocumented
Function _nexus_headers_to_context Undocumented
Type Alias _CarrierDict Undocumented
default_text_map_propagator = (source)

Default text map propagator used by TracingInterceptor.

def _context_to_headers(headers: Mapping[str, temporalio.api.common.v1.Payload]) -> Mapping[str, temporalio.api.common.v1.Payload]: (source)

Undocumented

def _context_to_nexus_headers(headers: Mapping[str, str]) -> Mapping[str, str]: (source)

Undocumented

def _headers_to_context(headers: Mapping[str, temporalio.api.common.v1.Payload]) -> Context: (source)

Undocumented

def _maybe_span(tracer: Tracer, name: str, *, add_temporal_spans: bool, attributes: opentelemetry.util.types.Attributes, kind: opentelemetry.trace.SpanKind, context: Context | None = None) -> Iterator[None]: (source)

Undocumented

def _nexus_headers_to_context(headers: Mapping[str, str]) -> Context: (source)

Undocumented

_CarrierDict: TypeAlias = (source)

Undocumented

Value
dict[str, opentelemetry.propagators.textmap.CarrierValT]