celery.exceptions

Celery error types.

exceptioncelery.exceptions.AlreadyRegistered

The task is already registered.

exceptioncelery.exceptions.AlwaysEagerIgnored

send_task ignores task_always_eager option.

exceptioncelery.exceptions.BackendError

An issue writing or reading to/from the backend.

exceptioncelery.exceptions.BackendGetMetaError(*args, **kwargs)

An issue reading from the backend.

exceptioncelery.exceptions.BackendStoreError(*args, **kwargs)

An issue writing to the backend.

exceptioncelery.exceptions.CDeprecationWarning

Warning of deprecation.

exceptioncelery.exceptions.CPendingDeprecationWarning

Warning of pending deprecation.

exceptioncelery.exceptions.CeleryCommandException(message, exit_code)

A general command exception which stores an exit code.

exceptioncelery.exceptions.CeleryError

Base class for all Celery errors.

exceptioncelery.exceptions.CeleryWarning

Base class for all Celery warnings.

exceptioncelery.exceptions.ChordError

A task part of the chord raised an exception.

exceptioncelery.exceptions.DuplicateNodenameWarning

Multiple workers are using the same nodename.

exceptioncelery.exceptions.FixupWarning

Fixup related warning.

exceptioncelery.exceptions.Ignore

A task can raise this to ignore doing state updates.

exceptioncelery.exceptions.ImproperlyConfigured

Celery is somehow improperly configured.

exceptioncelery.exceptions.IncompleteStream

Found the end of a stream of data, but the data isn’t complete.

exceptioncelery.exceptions.InvalidTaskError

The task has invalid data or ain’t properly constructed.

exceptioncelery.exceptions.MaxRetriesExceededError(*args, **kwargs)

The tasks max restart limit has been exceeded.

exceptioncelery.exceptions.NotConfigured

Celery hasn’t been configured, as no config module has been found.

exceptioncelery.exceptions.NotRegistered

The task is not registered.

exceptioncelery.exceptions.OperationalError

Recoverable message transport connection error.

exceptioncelery.exceptions.QueueNotFound

Task routed to a queue not in conf.queues.

exceptioncelery.exceptions.Reject(reason=None, requeue=False)

A task can raise this if it wants to reject/re-queue the message.

exceptioncelery.exceptions.Retry(message=None, exc=None, when=None, is_eager=False, sig=None, **kwargs)

The task is to be retried later.

exc=None

Exception (if any) that caused the retry to happen.

humanize()

message=None

Optional message describing context of retry.

when=None

Time of retry (ETA), either numbers.Real or datetime.

exceptioncelery.exceptions.SecurityError

Security related exception.

exceptioncelery.exceptions.SecurityWarning

Potential security issue found.

exceptioncelery.exceptions.SoftTimeLimitExceeded

The soft time limit has been exceeded. This exception is raised to give the task a chance to clean up.

exceptioncelery.exceptions.TaskError

Task related errors.

exceptioncelery.exceptions.TaskPredicate

Base class for task-related semi-predicates.

exceptioncelery.exceptions.TaskRevokedError

The task has been revoked, so no result available.

exceptioncelery.exceptions.Terminated

The worker processing a job has been terminated by user request.

exceptioncelery.exceptions.TimeLimitExceeded

The time limit has been exceeded and the job has been terminated.

exceptioncelery.exceptions.TimeoutError

The operation timed out.

exceptioncelery.exceptions.WorkerLostError

The worker processing a job has exited prematurely.

exceptioncelery.exceptions.WorkerShutdown

Signals that the worker should perform a warm shutdown.

exceptioncelery.exceptions.WorkerTerminate

Signals that the worker should terminate immediately.

celery.exceptions.reraise(tp, value, tb=None)

Reraise exception.