From b3b0be832ad98bcb6cae968275b5cdf7086e34fc Mon Sep 17 00:00:00 2001 From: Lynn Date: Tue, 30 Sep 2025 15:39:09 +0800 Subject: [PATCH] Fix: input (#10386) ### What problem does this PR solve? Fix input of some parser. ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue) --- rag/flow/parser/parser.py | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/rag/flow/parser/parser.py b/rag/flow/parser/parser.py index b154e7410..f4378855d 100644 --- a/rag/flow/parser/parser.py +++ b/rag/flow/parser/parser.py @@ -337,14 +337,12 @@ class Parser(ProcessBase): self.set_output("text", txt) - def _audio(self, from_upstream: ParserFromUpstream): + def _audio(self, name, blob): import os import tempfile self.callback(random.randint(1, 5) / 100.0, "Start to work on an audio.") - blob = from_upstream.blob - name = from_upstream.name conf = self._param.setups["audio"] self.set_output("output_format", conf["output_format"]) @@ -360,12 +358,9 @@ class Parser(ProcessBase): self.set_output("text", txt) - def _email(self, from_upstream: ParserFromUpstream): + def _email(self, name, blob): self.callback(random.randint(1, 5) / 100.0, "Start to work on an email.") - blob = from_upstream.blob - name = from_upstream.name - email_content = {} conf = self._param.setups["email"] target_fields = conf["fields"]