mirror of
https://github.com/wassname/ray.git
synced 2026-08-02 13:01:01 +08:00
[ray_client]: Fix multiple attempts at checking connection (#13422)
This commit is contained in:
@@ -65,6 +65,7 @@ class Worker:
|
||||
conn_attempts += 1
|
||||
try:
|
||||
grpc.channel_ready_future(self.channel).result(timeout=timeout)
|
||||
break
|
||||
except grpc.FutureTimeoutError:
|
||||
if conn_attempts >= connection_retries:
|
||||
raise ConnectionError("ray client connection timeout")
|
||||
|
||||
Reference in New Issue
Block a user