fix

routers/documents.py

@@ -63,9 +63,9 @@ async def upload_and_ingest_documents(
             file_hash = calculate_file_hash(temp_file_path)
 
             # 3. Kiểm tra trùng lặp
-            if check_if_hash_exists(file_hash):
-                skipped_files.append({"filename": file.filename, "reason": "Duplicate file (content already processed)"})
-                os.remove(temp_file_path) # Xóa file tạm
+            if await check_if_hash_exists(file_hash):
+                skipped_files.append({"filename": file.filename, "reason": "Duplicate file content"})
+                os.remove(temp_file_path)
                 continue
 
             # 4. File hợp lệ, chuẩn bị để xử lý
@@ -81,7 +81,7 @@ async def upload_and_ingest_documents(
             temp_file_path = None # Đánh dấu là đã di chuyển
 
             # 5. Thêm tác vụ nền cho file này
-            background_tasks.add_task(full_process_and_ingest_pipeline, final_file_path, file_hash,embedding_model)
+            background_tasks.add_task(await full_process_and_ingest_pipeline, final_file_path, file_hash,embedding_model)
 
             accepted_files.append({"filename": final_filename, "hash": file_hash})