temporalio.contrib.opentelemetry._TracingNexusOperationInboundInterceptor

class documentation

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

Constructor: _TracingNexusOperationInboundInterceptor(next, root)

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	`_context_from_nexus_headers`	Undocumented
Instance Variable	`_root`	Undocumented

Inherited from NexusOperationInboundInterceptor:

Instance Variable next Undocumented

def __init__(self, next: temporalio.worker.NexusOperationInboundInterceptor, root: TracingInterceptor): (source) ¶

overrides temporalio.worker.NexusOperationInboundInterceptor.__init__

Create the inbound interceptor.

Parameters
next:`temporalio.worker.NexusOperationInboundInterceptor`	The next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
root:`TracingInterceptor`	Undocumented

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 _context_from_nexus_headers(self, headers: Mapping[str, str]): (source) ¶

Undocumented

_root = (source) ¶

Undocumented