temporalio.bridge.client.Client

class documentation

class Client: (source)

Constructors: Client.connect(runtime, config), Client(runtime, ref)

RPC client using SDK Core.

Async Static Method	`connect`	Establish connection with server.
Method	`__init__`	Initialize client with underlying SDK Core reference.
Async Method	`call`	Make RPC call using SDK Core.
Method	`update_api_key`	Update underlying API key on Core client.
Method	`update_metadata`	Update underlying metadata on Core client.
Instance Variable	`_ref`	Undocumented
Instance Variable	`_runtime`	Undocumented

@staticmethod
async def connect(runtime: temporalio.bridge.runtime.Runtime, config: ClientConfig) -> Client: (source) ¶

Establish connection with server.

def __init__(self, runtime: temporalio.bridge.runtime.Runtime, ref: temporalio.bridge.temporal_sdk_bridge.ClientRef): (source) ¶

Initialize client with underlying SDK Core reference.

async def call(self, *, service: str, rpc: str, req: google.protobuf.message.Message, resp_type: Type[ProtoMessage], retry: bool, metadata: Mapping[str, str], timeout: Optional[timedelta]) -> ProtoMessage: (source) ¶

Make RPC call using SDK Core.

def update_api_key(self, api_key: Optional[str]): (source) ¶

Update underlying API key on Core client.

def update_metadata(self, metadata: Mapping[str, str]): (source) ¶

Update underlying metadata on Core client.

_ref = (source) ¶

Undocumented

_runtime = (source) ¶

Undocumented