class documentation

OutboundInterceptor for intercepting client calls.

This should be extended by any client outbound interceptors.

Method __init__ Create the outbound interceptor.
Async Method cancel_workflow Called for every WorkflowHandle.cancel call.
Async Method complete_async_activity Called for every AsyncActivityHandle.complete call.
Async Method describe_workflow Called for every WorkflowHandle.describe call.
Async Method fail_async_activity Called for every AsyncActivityHandle.fail call.
Async Method heartbeat_async_activity Called for every AsyncActivityHandle.heartbeat call.
Async Method query_workflow Called for every WorkflowHandle.query call.
Async Method report_cancellation_async_activity Called for every AsyncActivityHandle.report_cancellation call.
Async Method signal_workflow Called for every WorkflowHandle.signal call.
Async Method start_workflow Called for every Client.start_workflow call.
Async Method terminate_workflow Called for every WorkflowHandle.terminate call.
Instance Variable next Undocumented
def __init__(self, next: OutboundInterceptor): (source)

Create the outbound interceptor.

Parameters
next:OutboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
async def cancel_workflow(self, input: CancelWorkflowInput): (source)

Called for every WorkflowHandle.cancel call.

async def complete_async_activity(self, input: CompleteAsyncActivityInput): (source)

Called for every AsyncActivityHandle.complete call.

async def describe_workflow(self, input: DescribeWorkflowInput) -> WorkflowExecutionDescription: (source)

Called for every WorkflowHandle.describe call.

async def fail_async_activity(self, input: FailAsyncActivityInput): (source)

Called for every AsyncActivityHandle.fail call.

async def heartbeat_async_activity(self, input: HeartbeatAsyncActivityInput): (source)

Called for every AsyncActivityHandle.heartbeat call.

async def report_cancellation_async_activity(self, input: ReportCancellationAsyncActivityInput): (source)
async def terminate_workflow(self, input: TerminateWorkflowInput): (source)

Called for every WorkflowHandle.terminate call.

next = (source)

Undocumented