yujunjun/haystack
1
0
Fork 0
mirror of https://github.com/deepset-ai/haystack.git synced 2026-01-06 12:07:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Event sending for RayPipeline crashing Haystack (#3971)

Browse Source 
* 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>
This commit is contained in:
Zoltan Fedor 2023-02-02 02:27:20 -05:00 committed by GitHub
parent 9009a9ae58
commit 3aa6522564
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
haystack/pipelines/ray.py
View File

@ -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:
"""