class documentation
class CommandAwarePayloadVisitor(PayloadVisitor): (source)
Constructor: CommandAwarePayloadVisitor(skip_search_attributes, skip_headers)
Payload visitor that sets command context during traversal.
Override methods are explicitly defined for workflow commands and activation jobs that have both a 'seq' field and payloads to visit.
Inherited from PayloadVisitor
:
async def _visit_coresdk_workflow_activation_ResolveActivity(self, fs:
VisitorFunctions
, o: ResolveActivity
):
(source)
¶
overrides
temporalio.bridge._visitor.PayloadVisitor._visit_coresdk_workflow_activation_ResolveActivity
Undocumented
async def _visit_coresdk_workflow_activation_ResolveChildWorkflowExecution(self, fs:
VisitorFunctions
, o: ResolveChildWorkflowExecution
):
(source)
¶
async def _visit_coresdk_workflow_activation_ResolveChildWorkflowExecutionStart(self, fs:
VisitorFunctions
, o: ResolveChildWorkflowExecutionStart
):
(source)
¶
async def _visit_coresdk_workflow_activation_ResolveNexusOperation(self, fs:
VisitorFunctions
, o: ResolveNexusOperation
):
(source)
¶
async def _visit_coresdk_workflow_activation_ResolveNexusOperationStart(self, fs:
VisitorFunctions
, o: ResolveNexusOperationStart
):
(source)
¶
async def _visit_coresdk_workflow_activation_ResolveRequestCancelExternalWorkflow(self, fs:
VisitorFunctions
, o: ResolveRequestCancelExternalWorkflow
):
(source)
¶
async def _visit_coresdk_workflow_activation_ResolveSignalExternalWorkflow(self, fs:
VisitorFunctions
, o: ResolveSignalExternalWorkflow
):
(source)
¶
async def _visit_coresdk_workflow_commands_ScheduleActivity(self, fs:
VisitorFunctions
, o: ScheduleActivity
):
(source)
¶
overrides
temporalio.bridge._visitor.PayloadVisitor._visit_coresdk_workflow_commands_ScheduleActivity
Undocumented
async def _visit_coresdk_workflow_commands_ScheduleLocalActivity(self, fs:
VisitorFunctions
, o: ScheduleLocalActivity
):
(source)
¶
async def _visit_coresdk_workflow_commands_ScheduleNexusOperation(self, fs:
VisitorFunctions
, o: ScheduleNexusOperation
):
(source)
¶
async def _visit_coresdk_workflow_commands_SignalExternalWorkflowExecution(self, fs:
VisitorFunctions
, o: SignalExternalWorkflowExecution
):
(source)
¶
async def _visit_coresdk_workflow_commands_StartChildWorkflowExecution(self, fs:
VisitorFunctions
, o: StartChildWorkflowExecution
):
(source)
¶