temporalio.contrib.opentelemetry._otel_interceptor._TracingNexusOperationInboundInterceptor

class documentation

class _TracingNexusOperationInboundInterceptor(temporalio.worker.NexusOperationInboundInterceptor): (source)

Constructor: _TracingNexusOperationInboundInterceptor(next, add_temporal_spans)

View In Hierarchy

Undocumented

Method __init__ Create the inbound interceptor.
Async Method execute_nexus_operation_cancel Called to cancel an in progress Nexus operation
Async Method execute_nexus_operation_start Called to start a Nexus operation
Method _top_level_context Undocumented
Instance Variable _add_temporal_spans Undocumented

Inherited from NexusOperationInboundInterceptor:

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

Create the inbound interceptor.

Parameters
next:temporalio.worker.NexusOperationInboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
add_temporal_spans:boolUndocumented
async def execute_nexus_operation_cancel(self, input: temporalio.worker.ExecuteNexusOperationCancelInput): (source)
overrides temporalio.worker.NexusOperationInboundInterceptor.execute_nexus_operation_cancel

Called to cancel an in progress Nexus operation

async def execute_nexus_operation_start(self, input: temporalio.worker.ExecuteNexusOperationStartInput) -> nexusrpc.handler.StartOperationResultSync[Any] | nexusrpc.handler.StartOperationResultAsync: (source)
overrides temporalio.worker.NexusOperationInboundInterceptor.execute_nexus_operation_start

Called to start a Nexus operation

def _top_level_context(self, headers: Mapping[str, str]) -> Iterator[None]: (source)

Undocumented

_add_temporal_spans = (source)

Undocumented