Source code for redis_tasks.exceptions

[docs]class TaskAborted(Exception):
    def __init__(self, message):
        super().__init__(message)
        self.message = message




[docs]class TaskDoesNotExist(Exception):
    pass




[docs]class InvalidOperation(Exception):
    pass




[docs]class WorkerDoesNotExist(Exception):
    pass




[docs]class DeserializationError(Exception):
    def __init__(self, message, raw_data):
        super().__init__(message)
        self.raw_data = raw_data




[docs]class WorkerShutdown(BaseException):
    pass