Skip to content

Commit 02de79a

Browse files
committed
refactor
Signed-off-by: Sugam Devare <sdevare@nvidia.com>
1 parent 6ed57c4 commit 02de79a

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

nemo_gym/server_utils.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -317,13 +317,14 @@ def initialize_ray() -> None:
317317

318318
global_config_dict = get_global_config_dict()
319319
ray_head_node_address = global_config_dict.get("ray_head_node_address")
320-
320+
ray_init_kwargs = dict(ignore_reinit_error=True, runtime_env={"working_dir": PARENT_DIR})
321321
if ray_head_node_address is not None:
322322
print(f"Connecting to Ray cluster at specified address: {ray_head_node_address}")
323-
ray.init(address=ray_head_node_address, ignore_reinit_error=True, runtime_env={"working_dir": PARENT_DIR})
323+
ray_init_kwargs["address"] = ray_head_node_address
324324
else:
325325
print("Starting Ray cluster...")
326-
ray.init(ignore_reinit_error=True, runtime_env={"working_dir": PARENT_DIR})
326+
327+
ray.init(**ray_init_kwargs)
327328

328329

329330
class SimpleServer(BaseServer):

0 commit comments

Comments
 (0)