Spaces:
Running
Running
File size: 1,412 Bytes
29bfc1f | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 | """
src/api/jobs.py — Phase 3: Async upload job status endpoints
GET /api/jobs/{job_id} → poll job status + progress
This is the API router. The job queue worker lives in src/services/jobs.py.
"""
from fastapi import APIRouter, Depends, HTTPException, Request
from src.core.security import get_verified_keys
from src.core.logging import log
from src.services.jobs import get_job_status
from src.common.utils import get_ip
router = APIRouter()
@router.get("/api/jobs/{job_id}")
async def poll_job(
job_id: str,
request: Request,
keys: dict = Depends(get_verified_keys),
):
ip = get_ip(request)
job = await get_job_status(job_id)
if not job:
raise HTTPException(404, f"Job {job_id} not found")
total = job.get("total_files", 0)
processed = job.get("processed_files", 0)
pct = round(processed / total * 100) if total else 0
response = {
"job_id": job_id,
"status": job.get("status", "unknown"),
"total_files": total,
"processed_files": processed,
"progress_pct": pct,
"status_url": f"/api/jobs/{job_id}",
}
if job.get("status") == "completed":
response["result"] = job.get("result", {})
if job.get("status") == "failed":
response["error"] = job.get("error", "unknown error")
log("INFO", "jobs.poll", ip=ip, job_id=job_id, status=response["status"])
return response |