Spaces:
Running
Running
Update model.py
Browse files
model.py
CHANGED
|
@@ -1309,7 +1309,14 @@ async def query_document_info(niche_cases, query_word, alternative_query_word, s
|
|
| 1309 |
pipeline.process_link_chunk_allOutput(link, iso, acc, saveLinkFolder, out_links, all_output, chunk)
|
| 1310 |
for link in links
|
| 1311 |
]
|
| 1312 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1313 |
# combine results
|
| 1314 |
print("get results for context_for_llm")
|
| 1315 |
for context, new_all_output, new_chunk in results:
|
|
|
|
| 1309 |
pipeline.process_link_chunk_allOutput(link, iso, acc, saveLinkFolder, out_links, all_output, chunk)
|
| 1310 |
for link in links
|
| 1311 |
]
|
| 1312 |
+
print(f"Number of tasks to gather: {len(tasks)}")
|
| 1313 |
+
try:
|
| 1314 |
+
results = await asyncio.gather(*tasks)
|
| 1315 |
+
print("Finished gathering results")
|
| 1316 |
+
except Exception as e:
|
| 1317 |
+
print(f"Error in gathering: {e}")
|
| 1318 |
+
|
| 1319 |
+
#results = await asyncio.gather(*tasks)
|
| 1320 |
# combine results
|
| 1321 |
print("get results for context_for_llm")
|
| 1322 |
for context, new_all_output, new_chunk in results:
|