class documentation

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)

Create the inbound interceptor.

Parameters
next:WorkflowInboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
async def handle_query(self, input: HandleQueryInput) -> Any: (source)
async def handle_update_handler(self, input: HandleUpdateInput) -> Any: (source)

Called to handle an update's handler.

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

Called to handle an update's validation stage.

Initialize with an outbound interceptor.

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

Undocumented