temporalio.contrib.openai_agents._trace_interceptor._ContextPropagationWorkflowOutboundInterceptor

class documentation

class _ContextPropagationWorkflowOutboundInterceptor(temporalio.worker.WorkflowOutboundInterceptor, abc.ABC): (source)

Constructor: _ContextPropagationWorkflowOutboundInterceptor(next)

View In Hierarchy

Undocumented

Method root Undocumented
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.

Inherited from WorkflowOutboundInterceptor:

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 start_nexus_operation Called for every temporalio.workflow.NexusClient.start_operation call.
Instance Variable next Undocumented
Method _next_system_nexus_interceptor Undocumented

Inherited from _SystemNexusWorkflowOutboundInterceptorBase (via WorkflowOutboundInterceptor):

Async Method start_signal_with_start_workflow Intercept the SignalWithStartWorkflow operation.
def root(self): (source)

Undocumented

async def signal_child_workflow(self, input: temporalio.worker.SignalChildWorkflowInput): (source)
overrides temporalio.worker.WorkflowOutboundInterceptor.signal_child_workflow
async def signal_external_workflow(self, input: temporalio.worker.SignalExternalWorkflowInput): (source)
overrides temporalio.worker.WorkflowOutboundInterceptor.signal_external_workflow
def start_activity(self, input: temporalio.worker.StartActivityInput) -> temporalio.workflow.ActivityHandle: (source)
overrides temporalio.worker.WorkflowOutboundInterceptor.start_activity
async def start_child_workflow(self, input: temporalio.worker.StartChildWorkflowInput) -> temporalio.workflow.ChildWorkflowHandle: (source)
overrides temporalio.worker.WorkflowOutboundInterceptor.start_child_workflow
def start_local_activity(self, input: temporalio.worker.StartLocalActivityInput) -> temporalio.workflow.ActivityHandle: (source)
overrides temporalio.worker.WorkflowOutboundInterceptor.start_local_activity