---
estimated_steps: 1
estimated_files: 3
skills_used: []
---

# T02: Pipeline admin API endpoints

New router: GET /admin/pipeline/videos (list with status + event counts), POST /admin/pipeline/trigger/{video_id} (retrigger), POST /admin/pipeline/revoke/{video_id} (pause/stop via Celery revoke), GET /admin/pipeline/events/{video_id} (event log with pagination), GET /admin/pipeline/worker-status (active/reserved tasks from Celery inspect).

## Inputs

- `backend/routers/pipeline.py`
- `backend/models.py`
- `backend/schemas.py`

## Expected Output

- `backend/routers/pipeline.py (expanded with admin endpoints)`
- `backend/schemas.py (pipeline admin schemas)`

## Verification

curl -s http://localhost:8096/api/v1/admin/pipeline/videos | python3 -m json.tool && curl -s http://localhost:8096/api/v1/admin/pipeline/worker-status | python3 -m json.tool
