From 3aa652256453c6e30017ba765263cb7dba50afd6 Mon Sep 17 00:00:00 2001
From: Zoltan Fedor <zoltan.1.fedor@gmail.com>
Date: Thu, 2 Feb 2023 02:27:20 -0500
Subject: [PATCH] fix: Event sending for `RayPipeline` crashing Haystack
 (#3971)

* Remove the `send_pipeline_event_if_needed()` to confirm fix

* Suspending evnet sending for RayPipelines as it is not compatible

* Update base.py

* Updating implementation based on feedback from @masci

---------

Co-authored-by: Massimiliano Pippi <mpippi@gmail.com>
---
 haystack/pipelines/ray.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/haystack/pipelines/ray.py b/haystack/pipelines/ray.py
index 9fe5e00fc..76585bf2f 100644
--- a/haystack/pipelines/ray.py
+++ b/haystack/pipelines/ray.py
@@ -405,6 +405,11 @@ class RayPipeline(Pipeline):
         # self.send_pipeline_event_if_needed(is_indexing=file_paths is not None)
         return node_output
 
+    def send_pipeline_event(self, is_indexing: bool = False):
+        """To avoid the RayPipeline serialization bug described at
+        https://github.com/deepset-ai/haystack/issues/3970"""
+        pass
+
 
 class _RayDeploymentWrapper:
     """