[Core] convert gcs port read from env variable from str to int (ray-p…

…roject#34482)

convert the variable from str to int to close ray-project#33963

python/ray/_private/node.py

@@ -272,7 +272,7 @@ def __init__(
  if head:
  gcs_server_port = os.getenv(ray_constants.GCS_PORT_ENVIRONMENT_VARIABLE)
  if gcs_server_port:
- ray_params.update_if_absent(gcs_server_port=gcs_server_port)
+ ray_params.update_if_absent(gcs_server_port=int(gcs_server_port))
  if ray_params.gcs_server_port is None or ray_params.gcs_server_port == 0:
  ray_params.gcs_server_port = self._get_cached_port("gcs_server_port")
 

python/ray/tests/test_basic_5.py

@@ -6,6 +6,7 @@
 import time
 import subprocess
 from unittest.mock import Mock, patch
+import unittest
 
 import pytest
 
@@ -361,6 +362,16 @@ def verify_imports(latch):
  ray.get(futures)
 
 
+def test_gcs_port_env():
+ try:
+ with unittest.mock.patch.dict(os.environ):
+ os.environ["RAY_GCS_SERVER_PORT"] = "12345"
+ ray.init()
+ except RuntimeError:
+ pass
+ # it's ok to throw runtime error for port conflicts
+
+
 if __name__ == "__main__":
  if os.environ.get("PARALLEL_CI"):
  sys.exit(pytest.main(["-n", "auto", "--boxed", "-vs", __file__]))