GeezerVison

The World Wide Web, restored to 800 pixels of glory.

GeezerVison is showing python.temporal.io — temporalio.worker.WorkflowInboundInterceptor

`temporalio.worker.WorkflowInboundInterceptor`

class documentation

class WorkflowInboundInterceptor: (source)

Known subclasses: temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor, temporalio.testing._workflow._AssertionErrorWorkflowInboundInterceptor

Constructor: WorkflowInboundInterceptor(next)

View In Hierarchy

Inbound interceptor to wrap outbound creation, workflow execution, and signal/query handling.

This should be extended by any workflow inbound interceptors.

Method	`__init__`	Create the inbound interceptor.
Async Method	`execute_workflow`	Called to run the workflow.
Async Method	`handle_query`	Called to handle a query.
Async Method	`handle_signal`	Called to handle a signal.
Async Method	`handle_update_handler`	Called to handle an update's handler.
Method	`handle_update_validator`	Called to handle an update's validation stage.
Method	`init`	Initialize with an outbound interceptor.
Instance Variable	`next`	Undocumented

def __init__(self, next: WorkflowInboundInterceptor): (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor

Create the inbound interceptor.

Parameters
next:`WorkflowInboundInterceptor`	The next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.

async def execute_workflow(self, input: ExecuteWorkflowInput) -> Any: (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor, temporalio.testing._workflow._AssertionErrorWorkflowInboundInterceptor

Called to run the workflow.

async def handle_query(self, input: HandleQueryInput) -> Any: (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor

Called to handle a query.

async def handle_signal(self, input: HandleSignalInput): (source) ¶

Called to handle a signal.

async def handle_update_handler(self, input: HandleUpdateInput) -> Any: (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor

Called to handle an update's handler.

def handle_update_validator(self, input: HandleUpdateInput): (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor

Called to handle an update's validation stage.

def init(self, outbound: WorkflowOutboundInterceptor): (source) ¶

overridden in temporalio.contrib.opentelemetry.TracingWorkflowInboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingWorkflowInboundInterceptor

Initialize with an outbound interceptor.

To add a custom outbound interceptor, wrap the given interceptor before sending to the next init call.

next = (source) ¶

Undocumented

You are visitor 01402503 — GeezerVison does not store the pages you look up.
Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required.