Skip to content

Commit b8941a3

Browse files
Do not call ray init again if ray was already initialized
1 parent 63af7cc commit b8941a3

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/pydvl/utils/parallel/backend.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -136,9 +136,8 @@ def __init__(self, config: ParallelConfig):
136136
config_dict.pop("backend")
137137
config_dict["num_cpus"] = config_dict.pop("n_local_workers")
138138
self.config = config_dict
139-
if self.config["address"] is None:
140-
self.config["ignore_reinit_error"] = True
141-
ray.init(**self.config)
139+
if not ray.is_initialized():
140+
ray.init(**self.config)
142141

143142
def get(
144143
self,

0 commit comments

Comments
 (0)