Job status
thoth.ingestion.flows.job_status
¶
Job status and listing endpoints.
logger = setup_logger(__name__)
module-attribute
¶
get_job_status(request: Request) -> JSONResponse
async
¶
Get job status by ID.
Returns current status, statistics, and error information if failed.
list_jobs(request: Request) -> JSONResponse
async
¶
List recent jobs with optional filtering.
Query parameters
source: Filter by source name status: Filter by status (pending, running, completed, failed) limit: Maximum number of jobs (default: 50)