9
9
import pickle
10
10
import warnings
11
11
import zlib
12
- from collections .abc import Awaitable , Callable , Collection , Sequence
12
+ from collections .abc import Callable , Collection , Sequence
13
13
from enum import StrEnum , auto
14
14
from typing import TYPE_CHECKING , Any , ClassVar
15
15
from uuid import UUID
@@ -456,7 +456,7 @@ async def process_file(
456
456
manifest : dict [str , Any ],
457
457
semaphore : anyio .Semaphore ,
458
458
settings : Settings ,
459
- progress_bar_update : Callable [[], Awaitable ] | None = None ,
459
+ progress_bar_update : Callable [[], Any ] | None = None ,
460
460
) -> None :
461
461
abs_file_path = (
462
462
pathlib .Path (settings .agent .index .paper_directory ).absolute () / rel_file_path
@@ -500,7 +500,7 @@ async def process_file(
500
500
# separate process_file invocation leads to a segfault or crash
501
501
await search_index .save_index ()
502
502
if progress_bar_update :
503
- await progress_bar_update ()
503
+ progress_bar_update ()
504
504
return
505
505
506
506
this_doc = next (iter (tmp_docs .docs .values ()))
@@ -527,15 +527,15 @@ async def process_file(
527
527
528
528
# Update progress bar for either a new or previously indexed file
529
529
if progress_bar_update :
530
- await progress_bar_update ()
530
+ progress_bar_update ()
531
531
532
532
533
533
WARN_IF_INDEXING_MORE_THAN = 999
534
534
535
535
536
536
def _make_progress_bar_update (
537
537
sync_index_w_directory : bool , total : int
538
- ) -> tuple [contextlib .AbstractContextManager , Callable [[], Awaitable ] | None ]:
538
+ ) -> tuple [contextlib .AbstractContextManager , Callable [[], Any ] | None ]:
539
539
# Disable should override enable
540
540
env_var_disable = (
541
541
os .environ .get ("PQA_INDEX_DISABLE_PROGRESS_BAR" , "" ).lower () in ENV_VAR_MATCH
@@ -562,7 +562,7 @@ def _make_progress_bar_update(
562
562
)
563
563
task_id = progress .add_task ("Indexing..." , total = total )
564
564
565
- async def progress_bar_update () -> None :
565
+ def progress_bar_update () -> None :
566
566
progress .update (task_id , advance = 1 )
567
567
568
568
return progress , progress_bar_update
0 commit comments