class documentation
class NexusOperationInboundInterceptor: (source)
Known subclasses: temporalio.contrib.opentelemetry._interceptor._TracingNexusOperationInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingNexusOperationInboundInterceptor
Constructor: NexusOperationInboundInterceptor(next)
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 |
Called to cancel an in progress Nexus operation |
| Async Method | execute |
Called to start a Nexus operation |
| Instance Variable | next |
Undocumented |
overridden in
temporalio.contrib.opentelemetry._interceptor._TracingNexusOperationInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingNexusOperationInboundInterceptorCreate the inbound interceptor.
| Parameters | |
next:NexusOperationInboundInterceptor | The next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor. |
overridden in
temporalio.contrib.opentelemetry._interceptor._TracingNexusOperationInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingNexusOperationInboundInterceptorCalled to cancel an in progress Nexus operation
async def execute_nexus_operation_start(self, input:
ExecuteNexusOperationStartInput) -> nexusrpc.handler.StartOperationResultSync[:
(source)
¶
overridden in
temporalio.contrib.opentelemetry._interceptor._TracingNexusOperationInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingNexusOperationInboundInterceptorCalled to start a Nexus operation