thoth.ingestion.flows.job_status

Job status and listing endpoints.

Functions

get_job_manager()	Return the global JobManager singleton (creates on first call).
get_job_status(request)	Get job status by ID.
list_jobs(request)	List recent jobs with optional filtering.
setup_logger(name[, level, simple, json_output])	Create and configure a logger with structured JSON output.

Classes

JSONResponse(content[, status_code, ...])
JobStatus(*values)	Job status enumeration.
Request(scope, ~typing.Any], receive, ...)

async thoth.ingestion.flows.job_status.get_job_status(request: Request) → JSONResponse

Get job status by ID.

Returns current status, statistics, and error information if failed.

async thoth.ingestion.flows.job_status.list_jobs(request: Request) → JSONResponse

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)