feat: Support multiple RayPipelines (#4078)

deepset-ai · Feb 7, 2023 · a3016f0 · a3016f0
1 parent 3e4a220
commit a3016f0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/haystack/pipelines/ray.py b/haystack/pipelines/ray.py
@@ -77,7 +77,10 @@ def __init__(
  :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__()