Skip to content

Commit

Permalink
Detect old client
Browse files Browse the repository at this point in the history
Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com>
  • Loading branch information
jjyao committed Sep 13, 2024
1 parent bb15a35 commit 2acc718
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions python/ray/_raylet.pyx
Original file line number Diff line number Diff line change
Expand Up @@ -2689,6 +2689,8 @@ cdef class GcsClient:
cluster_id: str = None):
self.use_old_client = os.getenv("RAY_USE_OLD_GCS_CLIENT") == "1"
if self.use_old_client:
logger.error("OLD CLIENT IS USED!!!!!!!!")
os._exit(1)
self.inner = OldGcsClient(address, nums_reconnect_retry, cluster_id)
else:
# For timeout (DEADLINE_EXCEEDED): Both OldGcsClient and NewGcsClient
Expand Down

0 comments on commit 2acc718

Please sign in to comment.