class documentation
class CommandAwarePayloadVisitor(PayloadVisitor): (source)
Constructor: CommandAwarePayloadVisitor(skip_search_attributes, skip_headers, concurrency_limit)
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:
def __init__(self, *, skip_search_attributes:
bool = False, skip_headers: bool = False, concurrency_limit: int = 1):
(source)
¶
Creates a new command-aware payload visitor.
| Parameters | |
skipbool | If True, search attributes are not visited. |
skipbool | If True, headers are not visited. |
concurrencyint | Maximum number of payload visits that may run concurrently during a single call to visit(). Defaults to 1. |
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)
¶