temporalio.worker.WorkflowOutboundInterceptor

Modules Classes Names

class documentation

class WorkflowOutboundInterceptor: (source)

Known subclasses: temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._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.
Instance Variable	`next`	Undocumented

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

overridden in temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Create the outbound interceptor.

Parameters
next:`WorkflowOutboundInterceptor`	The 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._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.continue_as_new call.

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.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.ChildWorkflowHandle.signal call.

async def signal_external_workflow(self, input: SignalExternalWorkflowInput): (source) ¶

overridden in temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.ExternalWorkflowHandle.signal call.

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

overridden in temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.start_activity and temporalio.workflow.execute_activity call.

async def start_child_workflow(self, input: StartChildWorkflowInput) -> temporalio.workflow.ChildWorkflowHandle[Any, Any]: (source) ¶

overridden in temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.start_child_workflow and temporalio.workflow.execute_child_workflow call.

def start_local_activity(self, input: StartLocalActivityInput) -> temporalio.workflow.ActivityHandle[Any]: (source) ¶

overridden in temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor, temporalio.contrib.opentelemetry._TracingWorkflowOutboundInterceptor

Called for every temporalio.workflow.start_local_activity and temporalio.workflow.execute_local_activity call.

async def start_nexus_operation(self, input: StartNexusOperationInput[InputT, OutputT]) -> temporalio.workflow.NexusOperationHandle[OutputT]: (source) ¶

Called for every temporalio.workflow.NexusClient.start_operation call.

next = (source) ¶

Undocumented