temporalio.nexus._notification._OnCompleteCallback

class documentation

class _OnCompleteCallback(CompletionCallback[OutputT]): (source)

View In Hierarchy

Callback that calls an on-complete operation.

Class Variable operation Operation name.
Class Variable service Service name.
Class Variable source_context Value that the operation receives with the outcome.
Class Variable task_queue Task queue of the worker that runs the operation.
Async Method _to_proto Convert to proto representation.
operation: str = (source)

Operation name.

service: str = (source)

Service name.

source_context: Any = (source)

Value that the operation receives with the outcome.

The client encodes it with the serialization context of the source operation.

task_queue: str = (source)

Task queue of the worker that runs the operation.

async def _to_proto(self, data_converter: temporalio.converter.DataConverter) -> temporalio.api.common.v1.Callback: (source)
overrides temporalio.nexus.CompletionCallback._to_proto

Convert to proto representation.