mirror of
https://git.mirrors.martin98.com/https://github.com/infiniflow/ragflow.git
synced 2025-08-12 21:19:02 +08:00
fix emmpty input in graph (#1560)
### What problem does this PR solve? ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
parent
baeedc699d
commit
b06957e561
@ -456,12 +456,17 @@ class ComponentBase(ABC):
|
|||||||
break
|
break
|
||||||
break
|
break
|
||||||
if self.component_name.lower().find("answer") >= 0:
|
if self.component_name.lower().find("answer") >= 0:
|
||||||
if self.get_component_name(u) in ["relevant"]: continue
|
if self.get_component_name(u) in ["relevant"]:
|
||||||
|
continue
|
||||||
else: upstream_outs.append(self._canvas.get_component(u)["obj"].output(allow_partial=False)[1])
|
else:
|
||||||
|
o = self._canvas.get_component(u)["obj"].output(allow_partial=False)[1]
|
||||||
|
if o is not None:
|
||||||
|
upstream_outs.append(o)
|
||||||
break
|
break
|
||||||
|
|
||||||
return pd.concat(upstream_outs, ignore_index=False)
|
if upstream_outs:
|
||||||
|
return pd.concat(upstream_outs, ignore_index=False)
|
||||||
|
return pd.DataFrame()
|
||||||
|
|
||||||
def get_stream_input(self):
|
def get_stream_input(self):
|
||||||
reversed_cpnts = []
|
reversed_cpnts = []
|
||||||
|
Loading…
x
Reference in New Issue
Block a user