This document describes the current stable version of Celery (5.0). For development docs, go here.
celery.exceptions
¶
Celery error types.
Error Hierarchy¶
Exception
kombu.exceptions.KombuError
-
Raised when a transport connection error occurs while sending a message (be it a task, remote control command error).
Note
This exception does not inherit from
CeleryError
.
-
- billiard errors (prefork pool)
-
exception
celery.exceptions.
AlwaysEagerIgnored
[source]¶ send_task ignores
task_always_eager
option.
-
exception
celery.exceptions.
BackendGetMetaError
(*args, **kwargs)[source]¶ An issue reading from the backend.
-
exception
celery.exceptions.
BackendStoreError
(*args, **kwargs)[source]¶ An issue writing from the backend.
-
exception
celery.exceptions.
DuplicateNodenameWarning
[source]¶ Multiple workers are using the same nodename.
-
exception
celery.exceptions.
IncompleteStream
[source]¶ Found the end of a stream of data, but the data isn’t complete.
-
exception
celery.exceptions.
InvalidTaskError
[source]¶ The task has invalid data or ain’t properly constructed.
-
exception
celery.exceptions.
MaxRetriesExceededError
(*args, **kwargs)[source]¶ The tasks max restart limit has been exceeded.
-
exception
celery.exceptions.
NotConfigured
[source]¶ Celery hasn’t been configured, as no config module has been found.
-
exception
celery.exceptions.
OperationalError
[source]¶ Recoverable message transport connection error.
-
exception
celery.exceptions.
Reject
(reason=None, requeue=False)[source]¶ A task can raise this if it wants to reject/re-queue the message.
-
exception
celery.exceptions.
Retry
(message=None, exc=None, when=None, is_eager=False, sig=None, **kwargs)[source]¶ The task is to be retried later.
-
exc
= None¶ Exception (if any) that caused the retry to happen.
-
message
= None¶ Optional message describing context of retry.
-
when
= None¶ Time of retry (ETA), either
numbers.Real
ordatetime
.
-
-
exception
celery.exceptions.
SoftTimeLimitExceeded
[source]¶ The soft time limit has been exceeded. This exception is raised to give the task a chance to clean up.
-
exception
celery.exceptions.
TaskRevokedError
[source]¶ The task has been revoked, so no result available.
-
exception
celery.exceptions.
Terminated
[source]¶ The worker processing a job has been terminated by user request.
-
exception
celery.exceptions.
TimeLimitExceeded
[source]¶ The time limit has been exceeded and the job has been terminated.
-
exception
celery.exceptions.
WorkerLostError
[source]¶ The worker processing a job has exited prematurely.
-
exception
celery.exceptions.
WorkerShutdown
[source]¶ Signals that the worker should perform a warm shutdown.