GeezerVison

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

GeezerVison is showing python.temporal.io — temporalio.client.OutboundInterceptor

`temporalio.client.OutboundInterceptor`

class documentation

class OutboundInterceptor: (source)

Known subclasses: temporalio.client._ClientImpl, temporalio.contrib.opentelemetry._interceptor._TracingClientOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingClientOutboundInterceptor, temporalio.testing._timeskipping._TimeSkippingConfigOutbound, temporalio.testing._workflow._TimeSkippingClientOutboundInterceptor

Constructor: OutboundInterceptor(next)

View In Hierarchy

OutboundInterceptor for intercepting client calls.

This should be extended by any client outbound interceptors.

Method	`__init__`	Create the outbound interceptor.
Async Method	`backfill_schedule`	Called for every `ScheduleHandle.backfill` call.
Async Method	`cancel_activity`	Called for every `ActivityHandle.cancel` call.
Async Method	`cancel_nexus_operation`	Called for every `NexusOperationHandle.cancel` call.
Async Method	`cancel_workflow`	Called for every `WorkflowHandle.cancel` call.
Async Method	`complete_async_activity`	Called for every `AsyncActivityHandle.complete` call.
Async Method	`count_activities`	Called for every `Client.count_activities` call.
Async Method	`count_nexus_operations`	Called for every `Client.count_nexus_operations` call.
Async Method	`count_workflows`	Called for every `Client.count_workflows` call.
Async Method	`create_schedule`	Called for every `Client.create_schedule` call.
Async Method	`delete_schedule`	Called for every `ScheduleHandle.delete` call.
Async Method	`describe_activity`	Called for every `ActivityHandle.describe` call.
Async Method	`describe_nexus_operation`	Called for every `NexusOperationHandle.describe` call.
Async Method	`describe_schedule`	Called for every `ScheduleHandle.describe` call.
Async Method	`describe_workflow`	Called for every `WorkflowHandle.describe` call.
Async Method	`fail_async_activity`	Called for every `AsyncActivityHandle.fail` call.
Method	`fetch_workflow_history_events`	Called for every `WorkflowHandle.fetch_history_events` call.
Async Method	`get_nexus_operation_result`	Called for every `NexusOperationHandle.result` call.
Async Method	`get_worker_build_id_compatibility`	Called for every `Client.get_worker_build_id_compatibility` call.
Async Method	`get_worker_task_reachability`	Called for every `Client.get_worker_task_reachability` call.
Async Method	`heartbeat_async_activity`	Called for every `AsyncActivityHandle.heartbeat` call.
Method	`list_activities`	Called for every `Client.list_activities` call.
Method	`list_nexus_operations`	Called for every `Client.list_nexus_operations` call.
Method	`list_schedules`	Called for every `Client.list_schedules` call.
Method	`list_workflows`	Called for every `Client.list_workflows` call.
Async Method	`pause_activity`	Called for every `ActivityHandle.pause` call.
Async Method	`pause_schedule`	Called for every `ScheduleHandle.pause` 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_activity`	Called for every `Client.start_activity` call.
Async Method	`start_nexus_operation`	Called for every `NexusClient.start_operation` call.
Async Method	`start_update_with_start_workflow`	Called for every `Client.start_update_with_start_workflow` and `Client.execute_update_with_start_workflow` call.
Async Method	`start_workflow`	Called for every `Client.start_workflow` call.
Async Method	`start_workflow_update`	Called for every `WorkflowHandle.start_update` and `WorkflowHandle.execute_update` call.
Async Method	`terminate_activity`	Called for every `ActivityHandle.terminate` call.
Async Method	`terminate_nexus_operation`	Called for every `NexusOperationHandle.terminate` call.
Async Method	`terminate_workflow`	Called for every `WorkflowHandle.terminate` call.
Async Method	`trigger_schedule`	Called for every `ScheduleHandle.trigger` call.
Async Method	`unpause_activity`	Called for every `ActivityHandle.unpause` call.
Async Method	`unpause_schedule`	Called for every `ScheduleHandle.unpause` call.
Async Method	`update_activity_options`	Called for every `ActivityHandle.update_options` and `ActivityHandle.restore_original_options` call.
Async Method	`update_schedule`	Called for every `ScheduleHandle.update` call.
Async Method	`update_worker_build_id_compatibility`	Called for every `Client.update_worker_build_id_compatibility` call.
Instance Variable	`next`	Undocumented

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

overridden in temporalio.client._ClientImpl, temporalio.contrib.opentelemetry._interceptor._TracingClientOutboundInterceptor, temporalio.contrib.opentelemetry._otel_interceptor._TracingClientOutboundInterceptor, temporalio.testing._timeskipping._TimeSkippingConfigOutbound, temporalio.testing._workflow._TimeSkippingClientOutboundInterceptor

Create the outbound interceptor.

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

async def backfill_schedule(self, input: BackfillScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.backfill call.

async def cancel_activity(self, input: CancelActivityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.cancel call.

async def cancel_nexus_operation(self, input: CancelNexusOperationInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every NexusOperationHandle.cancel call.

Warning

This API is experimental and unstable.

async def cancel_workflow(self, input: CancelWorkflowInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every WorkflowHandle.cancel call.

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

overridden in temporalio.client._ClientImpl

Called for every AsyncActivityHandle.complete call.

async def count_activities(self, input: CountActivitiesInput) -> ActivityExecutionCount: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.count_activities call.

async def count_nexus_operations(self, input: CountNexusOperationsInput) -> NexusOperationExecutionCount: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.count_nexus_operations call.

Warning

This API is experimental and unstable.

async def count_workflows(self, input: CountWorkflowsInput) -> WorkflowExecutionCount: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.count_workflows call.

async def create_schedule(self, input: CreateScheduleInput) -> ScheduleHandle: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.create_schedule call.

async def delete_schedule(self, input: DeleteScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.delete call.

async def describe_activity(self, input: DescribeActivityInput) -> ActivityExecutionDescription: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.describe call.

async def describe_nexus_operation(self, input: DescribeNexusOperationInput) -> NexusOperationExecutionDescription: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every NexusOperationHandle.describe call.

Warning

This API is experimental and unstable.

async def describe_schedule(self, input: DescribeScheduleInput) -> ScheduleDescription: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.describe call.

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

overridden in temporalio.client._ClientImpl

Called for every WorkflowHandle.describe call.

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

overridden in temporalio.client._ClientImpl

Called for every AsyncActivityHandle.fail call.

def fetch_workflow_history_events(self, input: FetchWorkflowHistoryEventsInput) -> WorkflowHistoryEventAsyncIterator: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every WorkflowHandle.fetch_history_events call.

async def get_nexus_operation_result(self, input: GetNexusOperationResultInput) -> Any: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every NexusOperationHandle.result call.

Warning

This API is experimental and unstable.

async def get_worker_build_id_compatibility(self, input: GetWorkerBuildIdCompatibilityInput) -> WorkerBuildIdVersionSets: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.get_worker_build_id_compatibility call.

async def get_worker_task_reachability(self, input: GetWorkerTaskReachabilityInput) -> WorkerTaskReachability: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.get_worker_task_reachability call.

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

overridden in temporalio.client._ClientImpl

Called for every AsyncActivityHandle.heartbeat call.

def list_activities(self, input: ListActivitiesInput) -> ActivityExecutionAsyncIterator: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.list_activities call.

def list_nexus_operations(self, input: ListNexusOperationsInput) -> NexusOperationExecutionAsyncIterator: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.list_nexus_operations call.

Warning

This API is experimental and unstable.

def list_schedules(self, input: ListSchedulesInput) -> ScheduleAsyncIterator: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.list_schedules call.

def list_workflows(self, input: ListWorkflowsInput) -> WorkflowExecutionAsyncIterator: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.list_workflows call.

async def pause_activity(self, input: PauseActivityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.pause call.

Warning

This API is experimental.

async def pause_schedule(self, input: PauseScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.pause call.

async def query_workflow(self, input: QueryWorkflowInput) -> Any: (source) ¶

Called for every WorkflowHandle.query call.

async def report_cancellation_async_activity(self, input: ReportCancellationAsyncActivityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every AsyncActivityHandle.report_cancellation call.

async def signal_workflow(self, input: SignalWorkflowInput): (source) ¶

Called for every WorkflowHandle.signal call.

async def start_activity(self, input: StartActivityInput) -> ActivityHandle[Any]: (source) ¶

Called for every Client.start_activity call.

async def start_nexus_operation(self, input: StartNexusOperationInput) -> NexusOperationHandle[Any]: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every NexusClient.start_operation call.

Warning

This API is experimental and unstable.

async def start_update_with_start_workflow(self, input: StartWorkflowUpdateWithStartInput) -> WorkflowUpdateHandle[Any]: (source) ¶

Called for every Client.start_update_with_start_workflow and Client.execute_update_with_start_workflow call.

async def start_workflow(self, input: StartWorkflowInput) -> WorkflowHandle[Any, Any]: (source) ¶

Called for every Client.start_workflow call.

async def start_workflow_update(self, input: StartWorkflowUpdateInput) -> WorkflowUpdateHandle[Any]: (source) ¶

Called for every WorkflowHandle.start_update and WorkflowHandle.execute_update call.

async def terminate_activity(self, input: TerminateActivityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.terminate call.

async def terminate_nexus_operation(self, input: TerminateNexusOperationInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every NexusOperationHandle.terminate call.

Warning

This API is experimental and unstable.

async def terminate_workflow(self, input: TerminateWorkflowInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every WorkflowHandle.terminate call.

async def trigger_schedule(self, input: TriggerScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.trigger call.

async def unpause_activity(self, input: UnpauseActivityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.unpause call.

Warning

This API is experimental.

async def unpause_schedule(self, input: UnpauseScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.unpause call.

async def update_activity_options(self, input: UpdateActivityOptionsInput) -> ActivityExecutionOptions: (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ActivityHandle.update_options and ActivityHandle.restore_original_options call.

Warning

This API is experimental.

async def update_schedule(self, input: UpdateScheduleInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every ScheduleHandle.update call.

async def update_worker_build_id_compatibility(self, input: UpdateWorkerBuildIdCompatibilityInput): (source) ¶

overridden in temporalio.client._ClientImpl

Called for every Client.update_worker_build_id_compatibility call.

next = (source) ¶

Undocumented

You are visitor 01402520 — 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.