From abad2702827f355b85b9bf443490d6c35c276b8c Mon Sep 17 00:00:00 2001 From: Urtzi Alfaro Date: Sat, 26 Jul 2025 23:34:46 +0200 Subject: [PATCH] REFACTOR API gateway fix 9 --- services/training/app/api/training.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/services/training/app/api/training.py b/services/training/app/api/training.py index 7ba299c2..582fdaed 100644 --- a/services/training/app/api/training.py +++ b/services/training/app/api/training.py @@ -45,7 +45,7 @@ def get_training_service() -> TrainingService: """Factory function for TrainingService dependency""" return TrainingService() -@router.post("/tenants/{tenant_id}/jobs", response_model=TrainingJobResponse) +@router.post("/tenants/{tenant_id}/training/jobs", response_model=TrainingJobResponse) async def start_training_job( request: TrainingJobRequest, background_tasks: BackgroundTasks, @@ -110,7 +110,7 @@ async def start_training_job( tenant_id=tenant_id) raise HTTPException(status_code=500, detail=f"Failed to start training job: {str(e)}") -@router.get("/tenants/{tenant_id}/jobs", response_model=List[TrainingJobResponse]) +@router.get("/tenants/{tenant_id}/training/jobs", response_model=List[TrainingJobResponse]) async def get_training_jobs( status: Optional[TrainingStatus] = Query(None, description="Filter jobs by status"), limit: int = Query(100, ge=1, le=1000), @@ -146,7 +146,7 @@ async def get_training_jobs( tenant_id=tenant_id) raise HTTPException(status_code=500, detail=f"Failed to get training jobs: {str(e)}") -@router.get("/tenants/{tenant_id}/jobs/{job_id}", response_model=TrainingJobResponse) +@router.get("/tenants/{tenant_id}/training/jobs/{job_id}", response_model=TrainingJobResponse) async def get_training_job( job_id: str, tenant_id: UUID = Path(..., description="Tenant ID"), @@ -179,7 +179,7 @@ async def get_training_job( job_id=job_id) raise HTTPException(status_code=500, detail=f"Failed to get training job: {str(e)}") -@router.get("/tenants/{tenant_id}/jobs/{job_id}/progress", response_model=TrainingJobProgress) +@router.get("/tenants/{tenant_id}/training/jobs/{job_id}/progress", response_model=TrainingJobProgress) async def get_training_progress( job_id: str, tenant_id: UUID = Path(..., description="Tenant ID"), @@ -254,7 +254,7 @@ async def cancel_training_job( job_id=job_id) raise HTTPException(status_code=500, detail=f"Failed to cancel training job: {str(e)}") -@router.post("/tenants/{tenant_id}/products/{product_name}", response_model=TrainingJobResponse) +@router.post("/tenants/{tenant_id}/training/products/{product_name}", response_model=TrainingJobResponse) async def train_single_product( product_name: str, request: SingleProductTrainingRequest, @@ -309,7 +309,7 @@ async def train_single_product( tenant_id=tenant_id) raise HTTPException(status_code=500, detail=f"Failed to train product: {str(e)}") -@router.post("/tenants/{tenant_id}/validate", response_model=DataValidationResponse) +@router.post("/tenants/{tenant_id}/training/validate", response_model=DataValidationResponse) async def validate_training_data( request: DataValidationRequest, tenant_id: UUID = Path(..., description="Tenant ID"),