Skip to content
Fetching contributors…
Cannot retrieve contributors at this time
96 lines (54 sloc) 2.06 KB
# -*- coding: utf-8 -*-
This module contains Celery-specific exceptions.
:copyright: (c) 2009 - 2012 by Ask Solem.
:license: BSD, see LICENSE for more details.
from __future__ import absolute_import
from billiard.exceptions import ( # noqa
SoftTimeLimitExceeded, TimeLimitExceeded, WorkerLostError,
Task of kind %s is not registered, please make sure it's imported.\
class SecurityError(Exception):
"""Security related exceptions.
Handle with care.
class SystemTerminate(SystemExit):
"""Signals that the worker should terminate."""
class QueueNotFound(KeyError):
"""Task routed to a queue not in CELERY_QUEUES."""
class ImproperlyConfigured(ImportError):
"""Celery is somehow improperly configured."""
class NotRegistered(KeyError):
"""The task is not registered."""
def __repr__(self):
return UNREGISTERED_FMT % str(self)
class AlreadyRegistered(Exception):
"""The task is already registered."""
class TimeoutError(Exception):
"""The operation timed out."""
class MaxRetriesExceededError(Exception):
"""The tasks max restart limit has been exceeded."""
class RetryTaskError(Exception):
"""The task is to be retried later."""
def __init__(self, message, exc, *args, **kwargs):
self.exc = exc
Exception.__init__(self, message, exc, *args, **kwargs)
class TaskRevokedError(Exception):
"""The task has been revoked, so no result available."""
class NotConfigured(UserWarning):
"""Celery has not been configured, as no config module has been found."""
class AlwaysEagerIgnored(UserWarning):
"""send_task ignores CELERY_ALWAYS_EAGER option"""
class InvalidTaskError(Exception):
"""The task has invalid data or is not properly constructed."""
class CPendingDeprecationWarning(PendingDeprecationWarning):
class CDeprecationWarning(DeprecationWarning):
class IncompleteStream(Exception):
"""Found the end of a stream of data, but the data is not yet complete."""
Something went wrong with that request. Please try again.