feat: add endpoint to trigger db update
This commit is contained in:
parent
4c1dc3d4fa
commit
ed8dd344d7
1 changed files with 4 additions and 1 deletions
|
|
@ -7,7 +7,7 @@ from fastapi import Depends
|
||||||
|
|
||||||
from src.dataprocessor.schemas import UpdateDbResponse
|
from src.dataprocessor.schemas import UpdateDbResponse
|
||||||
from src.dependencies import require_pp_api_key
|
from src.dependencies import require_pp_api_key
|
||||||
|
from src.dataprocessor.service import DataProcessorService
|
||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
@ -18,3 +18,6 @@ logger = logging.getLogger(__name__)
|
||||||
@router.post("/update-db")
|
@router.post("/update-db")
|
||||||
async def update_db(*, _: None = Depends(require_pp_api_key)) -> UpdateDbResponse:
|
async def update_db(*, _: None = Depends(require_pp_api_key)) -> UpdateDbResponse:
|
||||||
"""Endpoint to update the AI-database."""
|
"""Endpoint to update the AI-database."""
|
||||||
|
service = await DataProcessorService.create()
|
||||||
|
await service.update_database()
|
||||||
|
return UpdateDbResponse(success=True)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue