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_ResolveActivityUndocumented
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_ScheduleActivityUndocumented
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)
¶