Update document_routes.py
This commit is contained in:
parent
cb003593df
commit
bd533783e1
1 changed files with 8 additions and 8 deletions
|
|
@ -1499,15 +1499,15 @@ async def run_scanning_process(
|
||||||
if new_files:
|
if new_files:
|
||||||
# Process all files at once with track_id
|
# Process all files at once with track_id
|
||||||
if is_pipeline_busy:
|
if is_pipeline_busy:
|
||||||
logger.info(
|
logger.info(
|
||||||
"Pipe is currently busy, skipping processing to avoid conflicts..."
|
"Pipe is currently busy, skipping processing to avoid conflicts..."
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
if is_pipeline_scan_busy:
|
if is_pipeline_scan_busy:
|
||||||
logger.info(
|
logger.info(
|
||||||
"Pipe is currently busy, skipping processing to avoid conflicts..."
|
"Pipe is currently busy, skipping processing to avoid conflicts..."
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
if scheme_name == "lightrag":
|
if scheme_name == "lightrag":
|
||||||
await pipeline_index_files(
|
await pipeline_index_files(
|
||||||
rag, new_files, track_id, scheme_name=scheme_name
|
rag, new_files, track_id, scheme_name=scheme_name
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue