Remove local from ray.init call (#1708)

jaidisido · web-flow · commit f38a00e14ea4 · 2022-10-25T11:28:16.000+01:00
* Minor - remove local from ray.init

* [skip ci] - logger msg
diff --git a/awswrangler/distributed/ray/_core.py b/awswrangler/distributed/ray/_core.py
@@ -146,7 +146,6 @@ def initialize_ray(
             ]
 
             ray_init_kwargs = {
-                "address": "local",
                 "num_cpus": cpu_count,
                 "num_gpus": gpu_count,
                 "include_dashboard": include_dashboard,
@@ -159,5 +158,5 @@ def initialize_ray(
                     "env_vars": {var: os.environ.get(var) for var in ray_runtime_env_vars if os.environ.get(var)}
                 },
             }
-            _logger.info("Starting a local Ray cluster")
+            _logger.info("Starting a Ray cluster")
             ray.init(**ray_init_kwargs)

Original file line number	Diff line number	Diff line change
`@@ -146,7 +146,6 @@ def initialize_ray(`
`146`	`146`	`]`
`147`	`147`
`148`	`148`	`ray_init_kwargs = {`
`149`		`- "address": "local",`
`150`	`149`	`"num_cpus": cpu_count,`
`151`	`150`	`"num_gpus": gpu_count,`
`152`	`151`	`"include_dashboard": include_dashboard,`
`@@ -159,5 +158,5 @@ def initialize_ray(`
`159`	`158`	`"env_vars": {var: os.environ.get(var) for var in ray_runtime_env_vars if os.environ.get(var)}`
`160`	`159`	`},`
`161`	`160`	`}`
`162`		`- _logger.info("Starting a local Ray cluster")`
	`161`	`+ _logger.info("Starting a Ray cluster")`
`163`	`162`	`ray.init(**ray_init_kwargs)`