All werk exceptions inherit from WerkError.

WerkError

class WerkError(Exception): ...

Base exception for all werk errors.

JobNotFound

class JobNotFound(WerkError): ...

Raised by app.get_job() when no job with the given ID exists in the database.

from pgwerk import JobNotFound

try:
    job = await app.get_job("nonexistent-id")
except JobNotFound:
    print("Job not found")

JobTimeout

class JobTimeout(WerkError): ...

Raised inside a job handler when the job exceeds its configured _timeout.

JobError

class JobError(WerkError):
    job: Job

Raised by app.apply() and app.map() when a job reaches a failed or aborted terminal state. The job attribute holds the terminal Job object for inspection.

from pgwerk import JobError

try:
    result = await app.apply(risky_func, timeout=30)
except JobError as exc:
    print(f"Job {exc.job.id} failed: {exc.job.error}")

DependencyFailed

class DependencyFailed(WerkError): ...

Raised when a job cannot start because one of its dependencies failed and allow_failure was not set on the Dependency.

WorkerShutdown

class WorkerShutdown(WerkError): ...

Internal exception signalling that the worker received a shutdown signal. Not normally raised to application code.