rag
This commit is contained in:
parent
fe095316c8
commit
bd18c0c810
@ -253,7 +253,6 @@ where a.orgid = b.orgid
|
|||||||
) for chunk in chunk_texts
|
) for chunk in chunk_texts
|
||||||
]
|
]
|
||||||
results = await asyncio.gather(*tasks, return_exceptions=True)
|
results = await asyncio.gather(*tasks, return_exceptions=True)
|
||||||
debug(f"结果:{results}")
|
|
||||||
triples = []
|
triples = []
|
||||||
for i, result in enumerate(results):
|
for i, result in enumerate(results):
|
||||||
if isinstance(result, list):
|
if isinstance(result, list):
|
||||||
@ -349,7 +348,7 @@ where a.orgid = b.orgid
|
|||||||
id = rec.get('id', '')
|
id = rec.get('id', '')
|
||||||
realpath = rec.get('realpath', '')
|
realpath = rec.get('realpath', '')
|
||||||
fiid = rec.get('fiid', '')
|
fiid = rec.get('fiid', '')
|
||||||
orgid = rec.get('orgid', '')
|
orgid = rec.get('ownerid', '')
|
||||||
db_type = ''
|
db_type = ''
|
||||||
collection_name = "ragdb" if not db_type else f"ragdb_{db_type}"
|
collection_name = "ragdb" if not db_type else f"ragdb_{db_type}"
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user