Spaces:
Running
Running
Update pipeline.py
Browse files- pipeline.py +4 -2
pipeline.py
CHANGED
|
@@ -327,7 +327,7 @@ def pipeline_with_gemini(accessions,stop_flag=None, niche_cases=None, save_df=No
|
|
| 327 |
saveName = saveTitle.replace(" ", "_")
|
| 328 |
chunk_filename = f"{saveName}_merged_document.docx"
|
| 329 |
all_filename = f"{saveName}_all_merged_document.docx"
|
| 330 |
-
print(chunk_filename, all_filename)
|
| 331 |
# Define local temp paths for reading/writing
|
| 332 |
# import tempfile
|
| 333 |
# tmp_dir = tempfile.mkdtemp()
|
|
@@ -340,7 +340,7 @@ def pipeline_with_gemini(accessions,stop_flag=None, niche_cases=None, save_df=No
|
|
| 340 |
if stop_flag is not None and stop_flag.value:
|
| 341 |
print(f"🛑 Stop processing {accession}, aborting early...")
|
| 342 |
return {}
|
| 343 |
-
print(file_chunk_path)
|
| 344 |
chunk_id = find_drive_file(chunk_filename, sample_folder_id)
|
| 345 |
all_id = find_drive_file(all_filename, sample_folder_id)
|
| 346 |
|
|
@@ -447,6 +447,8 @@ def pipeline_with_gemini(accessions,stop_flag=None, niche_cases=None, save_df=No
|
|
| 447 |
acc_score["source"] = links
|
| 448 |
else:
|
| 449 |
print("no chunk or all output")
|
|
|
|
|
|
|
| 450 |
try:
|
| 451 |
temp_source = False
|
| 452 |
if save_df is not None and not save_df.empty:
|
|
|
|
| 327 |
saveName = saveTitle.replace(" ", "_")
|
| 328 |
chunk_filename = f"{saveName}_merged_document.docx"
|
| 329 |
all_filename = f"{saveName}_all_merged_document.docx"
|
| 330 |
+
print("chunk file name and all filename: ", chunk_filename, all_filename)
|
| 331 |
# Define local temp paths for reading/writing
|
| 332 |
# import tempfile
|
| 333 |
# tmp_dir = tempfile.mkdtemp()
|
|
|
|
| 340 |
if stop_flag is not None and stop_flag.value:
|
| 341 |
print(f"🛑 Stop processing {accession}, aborting early...")
|
| 342 |
return {}
|
| 343 |
+
print("this is file chunk path: ", file_chunk_path)
|
| 344 |
chunk_id = find_drive_file(chunk_filename, sample_folder_id)
|
| 345 |
all_id = find_drive_file(all_filename, sample_folder_id)
|
| 346 |
|
|
|
|
| 447 |
acc_score["source"] = links
|
| 448 |
else:
|
| 449 |
print("no chunk or all output")
|
| 450 |
+
print("chunk filename: ", str(chunks_filename))
|
| 451 |
+
|
| 452 |
try:
|
| 453 |
temp_source = False
|
| 454 |
if save_df is not None and not save_df.empty:
|