yujunjun/openspg
1
0
Fork 0
mirror of https://github.com/OpenSPG/openspg.git synced 2025-11-26 07:11:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Qu 2023-12-28 21:30:46 +08:00
parent 64e07ce051
commit 883b8efe6e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
python/knext/knext/operator/op.py
View File

@ -100,11 +100,11 @@ class FuseOp(BaseOp, ABC):
) )
def invoke(self, subject_records: List[SPGRecord]) -> List[SPGRecord]: def invoke(self, subject_records: List[SPGRecord]) -> List[SPGRecord]:
merged_records = []
for record in subject_records: for record in subject_records:
linked_records = self.link(record) linked_records = self.link(record)
merged_records = self.merge(record, linked_records) merged_records.extend(self.merge(record, linked_records))
return merged_records return merged_records
return []
@staticmethod @staticmethod
def _pre_process(*inputs): def _pre_process(*inputs):