temporalio.client._nexus._NexusClient

class documentation

class _NexusClient(NexusClient[NexusServiceType]): (source)

Constructor: _NexusClient(client, service, endpoint)

View In Hierarchy

Concrete implementation of NexusClient.

Method __init__ Undocumented
Async Method execute_operation Start a Nexus operation and wait for its result.
Async Method start_operation Start a Nexus operation and return a handle.
Method _resolve_operation Resolve an operation to its name and output type.
Instance Variable _client Undocumented
Instance Variable _endpoint Undocumented
Instance Variable _service_name Undocumented
def __init__(self, client: Client, service: type[NexusServiceType] | str, endpoint: str): (source)

Undocumented

async def execute_operation(self, operation: nexusrpc.Operation[Any, Any] | str | Callable[..., Any], arg: Any, *, id: str, id_reuse_policy: temporalio.common.NexusOperationIDReusePolicy = temporalio.common.NexusOperationIDReusePolicy.ALLOW_DUPLICATE, id_conflict_policy: temporalio.common.NexusOperationIDConflictPolicy = temporalio.common.NexusOperationIDConflictPolicy.FAIL, result_type: type | None = None, schedule_to_close_timeout: timedelta | None = None, schedule_to_start_timeout: timedelta | None = None, start_to_close_timeout: timedelta | None = None, search_attributes: temporalio.common.TypedSearchAttributes | None = None, summary: str | None = None, headers: Mapping[str, str] | None = None, rpc_metadata: Mapping[str, str | bytes] = {}, rpc_timeout: timedelta | None = None) -> Any: (source)
overrides temporalio.client.NexusClient.execute_operation

Start a Nexus operation and wait for its result.

Warning

This API is experimental and unstable.

async def start_operation(self, operation: nexusrpc.Operation[Any, Any] | str | Callable[..., Any], arg: Any, *, id: str, id_reuse_policy: temporalio.common.NexusOperationIDReusePolicy = temporalio.common.NexusOperationIDReusePolicy.ALLOW_DUPLICATE, id_conflict_policy: temporalio.common.NexusOperationIDConflictPolicy = temporalio.common.NexusOperationIDConflictPolicy.FAIL, result_type: type | None = None, schedule_to_close_timeout: timedelta | None = None, schedule_to_start_timeout: timedelta | None = None, start_to_close_timeout: timedelta | None = None, search_attributes: temporalio.common.TypedSearchAttributes | None = None, summary: str | None = None, headers: Mapping[str, str] | None = None, rpc_metadata: Mapping[str, str | bytes] = {}, rpc_timeout: timedelta | None = None) -> NexusOperationHandle[Any]: (source)
overrides temporalio.client.NexusClient.start_operation

Start a Nexus operation and return a handle.

Warning

This API is experimental and unstable.

def _resolve_operation(self, operation: nexusrpc.Operation[Any, Any] | str | Callable[..., Any]) -> tuple[str, type | None]: (source)

Resolve an operation to its name and output type.

_client = (source)

Undocumented

_endpoint = (source)

Undocumented

_service_name = (source)

Undocumented