temporalio.bridge._visitor.PayloadVisitor

class documentation

class PayloadVisitor: (source)

Known subclasses: temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Constructor: PayloadVisitor(skip_search_attributes, skip_headers, concurrency_limit)

View In Hierarchy

A visitor for payloads. Applies a function to every payload in a tree of messages.

Method __init__ Creates a new payload visitor.
Async Method visit Visits the given root message with the given function.
Instance Variable skip_headers Undocumented
Instance Variable skip_search_attributes Undocumented
Async Method _visit_coresdk_activity_result_ActivityResolution Undocumented
Async Method _visit_coresdk_activity_result_Cancellation Undocumented
Async Method _visit_coresdk_activity_result_Failure Undocumented
Async Method _visit_coresdk_activity_result_Success Undocumented
Async Method _visit_coresdk_child_workflow_Cancellation Undocumented
Async Method _visit_coresdk_child_workflow_ChildWorkflowResult Undocumented
Async Method _visit_coresdk_child_workflow_Failure Undocumented
Async Method _visit_coresdk_child_workflow_Success Undocumented
Async Method _visit_coresdk_nexus_NexusOperationResult Undocumented
Async Method _visit_coresdk_workflow_activation_DoUpdate Undocumented
Async Method _visit_coresdk_workflow_activation_InitializeWorkflow Undocumented
Async Method _visit_coresdk_workflow_activation_QueryWorkflow Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveActivity Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveChildWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveChildWorkflowExecutionStart Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveChildWorkflowExecutionStartCancelled Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveNexusOperation Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveNexusOperationStart Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveRequestCancelExternalWorkflow Undocumented
Async Method _visit_coresdk_workflow_activation_ResolveSignalExternalWorkflow Undocumented
Async Method _visit_coresdk_workflow_activation_SignalWorkflow Undocumented
Async Method _visit_coresdk_workflow_activation_WorkflowActivation Undocumented
Async Method _visit_coresdk_workflow_activation_WorkflowActivationJob Undocumented
Async Method _visit_coresdk_workflow_commands_CompleteWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_commands_ContinueAsNewWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_commands_FailWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_commands_ModifyWorkflowProperties Undocumented
Async Method _visit_coresdk_workflow_commands_QueryResult Undocumented
Async Method _visit_coresdk_workflow_commands_QuerySuccess Undocumented
Async Method _visit_coresdk_workflow_commands_ScheduleActivity Undocumented
Async Method _visit_coresdk_workflow_commands_ScheduleLocalActivity Undocumented
Async Method _visit_coresdk_workflow_commands_ScheduleNexusOperation Undocumented
Async Method _visit_coresdk_workflow_commands_SignalExternalWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_commands_StartChildWorkflowExecution Undocumented
Async Method _visit_coresdk_workflow_commands_UpdateResponse Undocumented
Async Method _visit_coresdk_workflow_commands_UpsertWorkflowSearchAttributes Undocumented
Async Method _visit_coresdk_workflow_commands_WorkflowCommand Undocumented
Async Method _visit_coresdk_workflow_completion_Failure Undocumented
Async Method _visit_coresdk_workflow_completion_Success Undocumented
Async Method _visit_coresdk_workflow_completion_WorkflowActivationCompletion Undocumented
Async Method _visit_nexus_operation_input_payload Undocumented
Async Method _visit_payload_container Undocumented
Async Method _visit_temporal_api_common_v1_Memo Undocumented
Async Method _visit_temporal_api_common_v1_Payload Undocumented
Async Method _visit_temporal_api_common_v1_Payloads Undocumented
Async Method _visit_temporal_api_common_v1_SearchAttributes Undocumented
Async Method _visit_temporal_api_failure_v1_ApplicationFailureInfo Undocumented
Async Method _visit_temporal_api_failure_v1_CanceledFailureInfo Undocumented
Async Method _visit_temporal_api_failure_v1_Failure Undocumented
Async Method _visit_temporal_api_failure_v1_ResetWorkflowFailureInfo Undocumented
Async Method _visit_temporal_api_failure_v1_TimeoutFailureInfo Undocumented
Async Method _visit_temporal_api_sdk_v1_UserMetadata Undocumented
Instance Variable _concurrency_limit Undocumented
def __init__(self, *, skip_search_attributes: bool = False, skip_headers: bool = False, concurrency_limit: int = 1): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Creates a new payload visitor.

Parameters
skip_search_attributes:boolIf True, search attributes are not visited.
skip_headers:boolIf True, headers are not visited.
concurrency_limit:intMaximum number of payload visits that may run concurrently during a single call to visit(). Defaults to 1 (sequential).
async def visit(self, fs: VisitorFunctions, root: Any): (source)

Visits the given root message with the given function.

skip_headers = (source)

Undocumented

skip_search_attributes = (source)

Undocumented

async def _visit_coresdk_activity_result_ActivityResolution(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_activity_result_Cancellation(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_activity_result_Failure(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_activity_result_Success(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_child_workflow_Cancellation(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_child_workflow_ChildWorkflowResult(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_child_workflow_Failure(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_child_workflow_Success(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_nexus_NexusOperationResult(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_DoUpdate(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_InitializeWorkflow(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_QueryWorkflow(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_ResolveActivity(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveChildWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveChildWorkflowExecutionStart(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveChildWorkflowExecutionStartCancelled(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_ResolveNexusOperation(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveNexusOperationStart(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveRequestCancelExternalWorkflow(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_ResolveSignalExternalWorkflow(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_activation_SignalWorkflow(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_WorkflowActivation(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_activation_WorkflowActivationJob(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_CompleteWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_ContinueAsNewWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_FailWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_ModifyWorkflowProperties(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_QueryResult(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_QuerySuccess(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_ScheduleActivity(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_ScheduleLocalActivity(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_ScheduleNexusOperation(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_SignalExternalWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_StartChildWorkflowExecution(self, fs: VisitorFunctions, o: Any): (source)
overridden in temporalio.worker._command_aware_visitor.CommandAwarePayloadVisitor

Undocumented

async def _visit_coresdk_workflow_commands_UpdateResponse(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_UpsertWorkflowSearchAttributes(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_commands_WorkflowCommand(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_completion_Failure(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_completion_Success(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_coresdk_workflow_completion_WorkflowActivationCompletion(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_nexus_operation_input_payload(self, fs: VisitorFunctions, service: str, operation: str, payload: Payload): (source)

Undocumented

async def _visit_payload_container(self, fs: VisitorFunctions, o: PayloadSequence): (source)

Undocumented

async def _visit_temporal_api_common_v1_Memo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_common_v1_Payload(self, fs: VisitorFunctions, o: Payload): (source)

Undocumented

async def _visit_temporal_api_common_v1_Payloads(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_common_v1_SearchAttributes(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_failure_v1_ApplicationFailureInfo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_failure_v1_CanceledFailureInfo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_failure_v1_Failure(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_failure_v1_ResetWorkflowFailureInfo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_failure_v1_TimeoutFailureInfo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_sdk_v1_UserMetadata(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

_concurrency_limit = (source)

Undocumented