From a3016f065f113aad06e48d13c264fbb0672c5f7b Mon Sep 17 00:00:00 2001
From: Zoltan Fedor <zoltan.1.fedor@gmail.com>
Date: Tue, 7 Feb 2023 05:01:07 -0500
Subject: [PATCH] feat: Support multiple `RayPipelines` (#4078)

---
 haystack/pipelines/ray.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/haystack/pipelines/ray.py b/haystack/pipelines/ray.py
index 94f8a09ef..2d166a09f 100644
--- a/haystack/pipelines/ray.py
+++ b/haystack/pipelines/ray.py
@@ -77,7 +77,10 @@ class RayPipeline(Pipeline):
         :param serve_args: Optional parameters for initializing Ray Serve.
         """
         ray_args = ray_args or {}
-        ray.init(address=address, **ray_args)
+        if not ray.is_initialized():
+            ray.init(address=address, **ray_args)
+        else:
+            logger.warning("Ray was already initialized, so reusing that for this RayPipeline.")
         self._serve_controller_client = serve.start(**serve_args)
         super().__init__()