temporalio.bridge._visitor_functions.VisitorFunctions

class documentation

class VisitorFunctions(ABC): (source)

Known subclasses: temporalio.bridge._visitor_functions.BoundedVisitorFunctions, temporalio.bridge.worker._Visitor, temporalio.worker._nexus._PayloadTransformVisitor

View In Hierarchy

Functions invoked by generated payload visitors.

Method	`checkpoint`	Return a marker for visits scheduled after this point, if supported.
Async Method	`drain_since`	Wait for visits scheduled after `checkpoint` to finish.
Async Method	`visit_payload`	Visit a single payload.
Async Method	`visit_payloads`	Visit a sequence of payloads together.
Async Method	`visit_system_nexus_envelope`	Visit a recognized system Nexus envelope payload.

def checkpoint(self) -> int | None: (source) ¶

overridden in temporalio.bridge._visitor_functions.BoundedVisitorFunctions

Return a marker for visits scheduled after this point, if supported.

async def drain_since(self, _checkpoint: int): (source) ¶

overridden in temporalio.bridge._visitor_functions.BoundedVisitorFunctions

Wait for visits scheduled after checkpoint to finish.

@abstractmethod

async def visit_payload(self, payload: Payload): (source) ¶

overridden in temporalio.bridge._visitor_functions.BoundedVisitorFunctions, temporalio.bridge.worker._Visitor, temporalio.worker._nexus._PayloadTransformVisitor

Visit a single payload.

@abstractmethod

async def visit_payloads(self, payloads: PayloadSequence): (source) ¶

overridden in temporalio.bridge._visitor_functions.BoundedVisitorFunctions, temporalio.bridge.worker._Visitor, temporalio.worker._nexus._PayloadTransformVisitor

Visit a sequence of payloads together.

async def visit_system_nexus_envelope(self, _payload: Payload): (source) ¶

overridden in temporalio.bridge._visitor_functions.BoundedVisitorFunctions

Visit a recognized system Nexus envelope payload.