class documentation
class _ContextPropagationWorkflowOutboundInterceptor(temporalio.worker.WorkflowOutboundInterceptor, abc.ABC): (source)
Constructor: _ContextPropagationWorkflowOutboundInterceptor(next)
Undocumented
| Method | root |
Undocumented |
| Async Method | signal |
Called for every temporalio.workflow.ChildWorkflowHandle.signal call. |
| Async Method | signal |
Called for every temporalio.workflow.ExternalWorkflowHandle.signal call. |
| Method | start |
Called for every temporalio.workflow.start_activity and temporalio.workflow.execute_activity call. |
| Async Method | start |
Called for every temporalio.workflow.start_child_workflow and temporalio.workflow.execute_child_workflow call. |
| Method | start |
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 |
Called for every temporalio.workflow.continue_as_new call. |
| Method | info |
Called for every temporalio.workflow.info call. |
| Async Method | start |
Called for every temporalio.workflow.NexusClient.start_operation call. |
| Instance Variable | next |
Undocumented |
async def signal_child_workflow(self, input:
temporalio.worker.SignalChildWorkflowInput):
(source)
¶
Called for every
temporalio.workflow.ChildWorkflowHandle.signal call.
async def signal_external_workflow(self, input:
temporalio.worker.SignalExternalWorkflowInput):
(source)
¶
Called for every
temporalio.workflow.ExternalWorkflowHandle.signal call.
def start_activity(self, input:
temporalio.worker.StartActivityInput) -> temporalio.workflow.ActivityHandle:
(source)
¶
Called for every temporalio.workflow.start_activity and
temporalio.workflow.execute_activity call.
async def start_child_workflow(self, input:
temporalio.worker.StartChildWorkflowInput) -> temporalio.workflow.ChildWorkflowHandle:
(source)
¶
Called for every temporalio.workflow.start_child_workflow
and temporalio.workflow.execute_child_workflow call.
def start_local_activity(self, input:
temporalio.worker.StartLocalActivityInput) -> temporalio.workflow.ActivityHandle:
(source)
¶
Called for every temporalio.workflow.start_local_activity
and temporalio.workflow.execute_local_activity call.