Ignore ray reinit errors in local execution

Ziemin · Ziemin · commit ad91a0c9f733 · 2025-06-16T12:19:57.000+02:00
diff --git a/plugins/flytekit-ray/flytekitplugins/ray/task.py b/plugins/flytekit-ray/flytekitplugins/ray/task.py
@@ -94,6 +94,8 @@ def pre_execute(self, user_params: ExecutionParameters) -> ExecutionParameters:
                 "working_dir": working_dir,
                 "excludes": ["script_mode.tar.gz", "fast*.tar.gz", ".python_history"],
             }
+        else:
+            init_params["ignore_reinit_error"] = True
 
         ray.init(**init_params)
         return user_params

Original file line number	Diff line number	Diff line change
`@@ -94,6 +94,8 @@ def pre_execute(self, user_params: ExecutionParameters) -> ExecutionParameters:`
`94`	`94`	`"working_dir": working_dir,`
`95`	`95`	`"excludes": ["script_mode.tar.gz", "fast*.tar.gz", ".python_history"],`
`96`	`96`	`}`
	`97`	`+ else:`
	`98`	`+ init_params["ignore_reinit_error"] = True`
`97`	`99`
`98`	`100`	`ray.init(**init_params)`
`99`	`101`	`return user_params`