Visitar URL original
temporalio.worker.WorkflowOutboundInterceptor

temporalio.worker.WorkflowOutboundInterceptor

class documentation

class WorkflowOutboundInterceptor(_SystemNexusWorkflowOutboundInterceptorBase): (source)

Known subclasses: temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor

Constructor: WorkflowOutboundInterceptor(next)

View In Hierarchy

Outbound interceptor to wrap calls made from within workflows.

This should be extended by any workflow outbound interceptors.

Method __init__ Create the outbound interceptor.
Method continue_as_new Called for every temporalio.workflow.continue_as_new call.
Method info Called for every temporalio.workflow.info call.
Async Method signal_child_workflow Called for every temporalio.workflow.ChildWorkflowHandle.signal call.
Async Method signal_external_workflow Called for every temporalio.workflow.ExternalWorkflowHandle.signal call.
Method start_activity Called for every temporalio.workflow.start_activity and temporalio.workflow.execute_activity call.
Async Method start_child_workflow Called for every temporalio.workflow.start_child_workflow and temporalio.workflow.execute_child_workflow call.
Method start_local_activity Called for every temporalio.workflow.start_local_activity and temporalio.workflow.execute_local_activity call.
Async Method start_nexus_operation Called for every temporalio.workflow.NexusClient.start_operation call.
Async Method start_system_nexus_operation Intercept a Temporal System Nexus operation started by a workflow.
Instance Variable next Undocumented
Method _next_system_nexus_interceptor Undocumented

Inherited from _SystemNexusWorkflowOutboundInterceptorBase:

Async Method start_signal_with_start_workflow Intercept the SignalWithStartWorkflow operation.
def __init__(self, next: WorkflowOutboundInterceptor): (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor

Create the outbound interceptor.

Parameters
next:WorkflowOutboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
def continue_as_new(self, input: ContinueAsNewInput) -> NoReturn: (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
def info(self) -> temporalio.workflow.Info: (source)

Called for every temporalio.workflow.info call.

async def signal_child_workflow(self, input: SignalChildWorkflowInput): (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
async def signal_external_workflow(self, input: SignalExternalWorkflowInput): (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
def start_activity(self, input: StartActivityInput) -> temporalio.workflow.ActivityHandle[Any]: (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
async def start_child_workflow(self, input: StartChildWorkflowInput) -> temporalio.workflow.ChildWorkflowHandle[Any, Any]: (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
def start_local_activity(self, input: StartLocalActivityInput) -> temporalio.workflow.ActivityHandle[Any]: (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
async def start_nexus_operation(self, input: StartNexusOperationInput[InputT, OutputT]) -> temporalio.workflow.NexusOperationHandle[OutputT]: (source)
overridden in temporalio.contrib.opentelemetry._interceptor._TracingWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowOutboundInterceptor
async def start_system_nexus_operation(self, input: StartNexusOperationInput[InputT, OutputT]) -> temporalio.workflow.NexusOperationHandle[OutputT]: (source)

Intercept a Temporal System Nexus operation started by a workflow.

next: WorkflowOutboundInterceptor = (source)

Undocumented

def _next_system_nexus_interceptor(self) -> _SystemNexusWorkflowOutboundInterceptorBase: (source)
overrides temporalio.nexus.system.workflow_service._system_nexus_interceptor._SystemNexusWorkflowOutboundInterceptorBase._next_system_nexus_interceptor

Undocumented