temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor

class documentation

class TracingWorkflowInboundInterceptor(temporalio.worker.WorkflowInboundInterceptor): (source)

Constructor: TracingWorkflowInboundInterceptor(next)

View In Hierarchy

Tracing interceptor for workflow calls.

See TracingInterceptor docs on why one might want to subclass this class.

Method __init__ Initialize a tracing workflow interceptor.
Async Method execute_workflow Implementation of temporalio.worker.WorkflowInboundInterceptor.execute_workflow.
Async Method handle_query Implementation of temporalio.worker.WorkflowInboundInterceptor.handle_query.
Async Method handle_signal Implementation of temporalio.worker.WorkflowInboundInterceptor.handle_signal.
Async Method handle_update_handler Implementation of temporalio.worker.WorkflowInboundInterceptor.handle_update_handler.
Method handle_update_validator Implementation of temporalio.worker.WorkflowInboundInterceptor.handle_update_validator.
Method init Implementation of temporalio.worker.WorkflowInboundInterceptor.init.
Instance Variable header_key Undocumented
Instance Variable payload_converter Undocumented
Instance Variable text_map_propagator Undocumented
Static Method _from_context Undocumented
Method _completed_span Undocumented
Method _context_carrier_to_headers Undocumented
Method _context_to_headers Undocumented
Method _load_workflow_context_carrier Undocumented
Method _set_on_context Undocumented
Method _top_level_workflow_context Undocumented
Instance Variable _extern_functions Undocumented
Instance Variable _workflow_context_carrier Undocumented

Inherited from WorkflowInboundInterceptor:

Instance Variable next Undocumented
def __init__(self, next: temporalio.worker.WorkflowInboundInterceptor): (source)
overrides temporalio.worker.WorkflowInboundInterceptor.__init__

Initialize a tracing workflow interceptor.

async def execute_workflow(self, input: temporalio.worker.ExecuteWorkflowInput) -> Any: (source)
overrides temporalio.worker.WorkflowInboundInterceptor.execute_workflow
async def handle_query(self, input: temporalio.worker.HandleQueryInput) -> Any: (source)
overrides temporalio.worker.WorkflowInboundInterceptor.handle_query
async def handle_signal(self, input: temporalio.worker.HandleSignalInput): (source)
overrides temporalio.worker.WorkflowInboundInterceptor.handle_signal
async def handle_update_handler(self, input: temporalio.worker.HandleUpdateInput) -> Any: (source)
overrides temporalio.worker.WorkflowInboundInterceptor.handle_update_handler
def handle_update_validator(self, input: temporalio.worker.HandleUpdateInput): (source)
overrides temporalio.worker.WorkflowInboundInterceptor.handle_update_validator
def init(self, outbound: temporalio.worker.WorkflowOutboundInterceptor): (source)
overrides temporalio.worker.WorkflowInboundInterceptor.init
header_key: str = (source)

Undocumented

payload_converter = (source)

Undocumented

text_map_propagator: opentelemetry.propagators.textmap.TextMapPropagator = (source)

Undocumented

@staticmethod
def _from_context() -> TracingWorkflowInboundInterceptor | None: (source)

Undocumented

def _completed_span(self, span_name: str, *, link_context_carrier: _CarrierDict | None = None, add_to_outbound: _InputWithHeaders | None = None, new_span_even_on_replay: bool = False, additional_attributes: opentelemetry.util.types.Attributes = None, exception: Exception | None = None, kind: opentelemetry.trace.SpanKind = opentelemetry.trace.SpanKind.INTERNAL): (source)

Undocumented

def _context_carrier_to_headers(self, carrier: _CarrierDict, headers: Mapping[str, temporalio.api.common.v1.Payload]) -> Mapping[str, temporalio.api.common.v1.Payload]: (source)

Undocumented

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

Undocumented

def _load_workflow_context_carrier(self) -> _CarrierDict | None: (source)

Undocumented

def _set_on_context(self, context: opentelemetry.context.Context) -> opentelemetry.context.Context: (source)

Undocumented

@contextmanager
def _top_level_workflow_context(self, *, success_is_complete: bool) -> Iterator[None]: (source)

Undocumented

_extern_functions = (source)

Undocumented

_workflow_context_carrier: _CarrierDict | None = (source)

Undocumented