(self)
| 55 | self._reconnect = reconnect |
| 56 | |
| 57 | def _get_stub(self): |
| 58 | channel = grpc.insecure_channel(self._endpoint, options=self._options) |
| 59 | return coordinator_service_pb2_grpc.CoordinatorServiceStub(channel) |
| 60 | |
| 61 | def waiting_service_ready(self, timeout_seconds=60): |
| 62 | begin_time = time.time() |
no outgoing calls
no test coverage detected