diff --git a/backend/app/api/knowledge_base_routes.py b/backend/app/api/knowledge_base_routes.py index 969fd8c..e832e95 100644 --- a/backend/app/api/knowledge_base_routes.py +++ b/backend/app/api/knowledge_base_routes.py @@ -253,13 +253,14 @@ async def trigger_processing( user_id, user_name = await _get_user_info(db, user) - # Create the job + # Create the job and commit immediately so the background task can see it job = await repo.create_processing_job( knowledge_base_id=kb_id, total_documents=len(docs), triggered_by_id=user_id, triggered_by_name=user_name, ) + await db.commit() # Start background processing background_tasks.add_task(