temporalio.worker.NexusOperationInboundInterceptor

class documentation

class NexusOperationInboundInterceptor: (source)

Known subclasses: temporalio.contrib.opentelemetry._TracingNexusOperationInboundInterceptor

Constructor: NexusOperationInboundInterceptor(next)

View In Hierarchy

Inbound interceptor to wrap Nexus operation starting and cancelling.

This should be extended by any Nexus operation inbound interceptors.

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
Instance Variable next Undocumented
def __init__(self, next: NexusOperationInboundInterceptor): (source)
overridden in temporalio.contrib.opentelemetry._TracingNexusOperationInboundInterceptor

Create the inbound interceptor.

Parameters
next:NexusOperationInboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
async def execute_nexus_operation_cancel(self, input: ExecuteNexusOperationCancelInput): (source)
overridden in temporalio.contrib.opentelemetry._TracingNexusOperationInboundInterceptor

Called to cancel an in progress Nexus operation

async def execute_nexus_operation_start(self, input: ExecuteNexusOperationStartInput) -> nexusrpc.handler.StartOperationResultSync[Any] | nexusrpc.handler.StartOperationResultAsync: (source)
overridden in temporalio.contrib.opentelemetry._TracingNexusOperationInboundInterceptor

Called to start a Nexus operation

next = (source)

Undocumented