-
- async def get_client(self):
- if self.temporal_api in WFTemporal.clients:
- client = WFTemporal.clients[self.temporal_api]
- else:
- self.logger.debug(
- f"No cached client found, connecting to {self.temporal_api}"
- )
- client = await Client.connect(self.temporal_api)
- WFTemporal.clients[self.temporal_api] = client
-
- self.logger.debug(f"Using client {client} for {self.temporal_api}")
- return client