temporalio.contrib.opentelemetry

module documentation
(source)

OpenTelemetry interceptor that creates/propagates spans.

Class TracingInterceptor Interceptor that supports client and worker OpenTelemetry span creation and propagation.
Class TracingWorkflowInboundInterceptor Tracing interceptor for workflow calls.
Class workflow Contains static methods that are safe to call from within a workflow.
Variable default_text_map_propagator Default text map propagator used by TracingInterceptor.
Class _CompletedWorkflowSpanParams Undocumented
Class _InputWithHeaders Undocumented
Class _InputWithOperationContext Undocumented
Class _InputWithStringHeaders Undocumented
Class _TracingActivityInboundInterceptor Undocumented
Class _TracingClientOutboundInterceptor Undocumented
Class _TracingNexusOperationInboundInterceptor Undocumented
Class _TracingWorkflowOutboundInterceptor Undocumented
Class _WorkflowExternFunctions Undocumented
Function _carrier_to_nexus_headers Undocumented
Type Variable _ContextT Undocumented
Type Alias _CarrierDict Undocumented
Variable _interceptor_context_key Undocumented
default_text_map_propagator = (source)

Default text map propagator used by TracingInterceptor.

def _carrier_to_nexus_headers(carrier: _CarrierDict, initial: Mapping[str, str] | None = None) -> Mapping[str, str]: (source)

Undocumented

_ContextT = (source)

Undocumented

Value
TypeVar('_ContextT',
        bound=nexusrpc.handler.OperationContext)
_CarrierDict: TypeAlias = (source)

Undocumented

Value
dict[str, opentelemetry.propagators.textmap.CarrierValT]
_interceptor_context_key = (source)

Undocumented