from app.models.document import IngestRequest
from app.services import ingestion_service


async def run_ingestion_job(run_id: str, request: IngestRequest) -> None:
    """FastAPI BackgroundTask entry point for the ingestion pipeline."""
    await ingestion_service.process_ingestion(run_id, request)