Make Ingestion Status updated through api calls

app/main.py

@@ -7,6 +7,7 @@
 from app.web.routers.health import router as health_router
 from app.web.routers.pipelines import router as pipelines_router
 from app.web.routers.webhooks import router as webhooks_router
+from app.web.routers.ingestion_status import router as ingestion_status_router
 
 import logging
 from fastapi import FastAPI, Request, status
@@ -57,3 +58,4 @@ async def some_middleware(request: Request, call_next):
 app.include_router(health_router)
 app.include_router(pipelines_router)
 app.include_router(webhooks_router)
+app.include_router(ingestion_status_router)

app/pipeline/lecture_ingestion_pipeline.py

@@ -29,7 +29,7 @@
     CapabilityRequestHandler,
     RequirementList,
 )
-from ..web.status import IngestionStatusCallback
+from ..web.status import ingestion_status_callback
 from langchain_text_splitters import RecursiveCharacterTextSplitter
 
 batch_update_lock = threading.Lock()

app/web/routers/webhooks.py

@@ -9,8 +9,8 @@
 from app.domain.ingestion.ingestion_pipeline_execution_dto import (
     IngestionPipelineExecutionDto,
 )
-from ..status.IngestionStatusCallback import IngestionStatusCallback
-from ..status.LecturesDeletionStatusCallback import LecturesDeletionStatusCallback
+from ..status.ingestion_status_callback import IngestionStatusCallback
+from ..status.lecture_deletion_status_callback import LecturesDeletionStatusCallback
 from ...domain.ingestion.deletionPipelineExecutionDto import (
     LecturesDeletionExecutionDto,
 )