exceptions

Celery error types.

Error Hierarchy

  • Exception
    • celery.exceptions.CeleryError
      • ImproperlyConfigured
      • SecurityError
      • TaskPredicate
        • Ignore
        • Reject
        • Retry
      • TaskError
        • QueueNotFound
        • IncompleteStream
        • NotRegistered
        • AlreadyRegistered
        • TimeoutError
        • MaxRetriesExceededError
        • TaskRevokedError
        • InvalidTaskError
        • ChordError
    • kombu.exceptions.KombuError
      • OperationalError

        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)
      • SoftTimeLimitExceeded
      • TimeLimitExceeded
      • WorkerLostError
      • Terminated
  • UserWarning
    • CeleryWarning
      • AlwaysEagerIgnored
      • DuplicateNodenameWarning
      • FixupWarning
      • NotConfigured
  • BaseException
    • SystemExit
      • WorkerTerminate
      • WorkerShutdown

Module Contents

Classes

CeleryWarning() Base class for all Celery warnings.
AlwaysEagerIgnored() send_task ignores :setting:`task_always_eager` option.
DuplicateNodenameWarning() Multiple workers are using the same nodename.
FixupWarning() Fixup related warning.
NotConfigured() Celery hasn’t been configured, as no config module has been found.
CeleryError() Base class for all Celery errors.
TaskPredicate() Base class for task-related semi-predicates.
Retry(self,message=None,exc=None,when=None,**kwargs) The task is to be retried later.
Ignore() A task can raise this to ignore doing state updates.
Reject(self,reason=None,requeue=False) A task can raise this if it wants to reject/re-queue the message.
ImproperlyConfigured() Celery is somehow improperly configured.
SecurityError() Security related exception.
TaskError() Task related errors.
QueueNotFound() Task routed to a queue not in conf.queues.
IncompleteStream() Found the end of a stream of data, but the data isn’t complete.
NotRegistered() The task ain’t registered.
AlreadyRegistered() The task is already registered.
TimeoutError() The operation timed out.
MaxRetriesExceededError() The tasks max restart limit has been exceeded.
TaskRevokedError() The task has been revoked, so no result available.
InvalidTaskError() The task has invalid data or ain’t properly constructed.
ChordError() A task part of the chord raised an exception.
CPendingDeprecationWarning() Warning of pending deprecation.
CDeprecationWarning() Warning of deprecation.
WorkerTerminate() Signals that the worker should terminate immediately.
WorkerShutdown() Signals that the worker should perform a warm shutdown.
class CeleryWarning

Base class for all Celery warnings.

class AlwaysEagerIgnored

send_task ignores :setting:`task_always_eager` option.

class DuplicateNodenameWarning

Multiple workers are using the same nodename.

class FixupWarning

Fixup related warning.

class NotConfigured

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

class CeleryError

Base class for all Celery errors.

class TaskPredicate

Base class for task-related semi-predicates.

class Retry(message=None, exc=None, when=None, **kwargs)

The task is to be retried later.

__init__(message=None, exc=None, when=None, **kwargs)
humanize()
__str__()
__reduce__()
class Ignore

A task can raise this to ignore doing state updates.

class Reject(reason=None, requeue=False)

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

__init__(reason=None, requeue=False)
__repr__()
class ImproperlyConfigured

Celery is somehow improperly configured.

class SecurityError

Security related exception.

class TaskError

Task related errors.

class QueueNotFound

Task routed to a queue not in conf.queues.

class IncompleteStream

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

class NotRegistered

The task ain’t registered.

__repr__()
class AlreadyRegistered

The task is already registered.

class TimeoutError

The operation timed out.

class MaxRetriesExceededError

The tasks max restart limit has been exceeded.

class TaskRevokedError

The task has been revoked, so no result available.

class InvalidTaskError

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

class ChordError

A task part of the chord raised an exception.

class CPendingDeprecationWarning

Warning of pending deprecation.

class CDeprecationWarning

Warning of deprecation.

class WorkerTerminate

Signals that the worker should terminate immediately.

class WorkerShutdown

Signals that the worker should perform a warm shutdown.