Source code for connector.exception

# -*- coding: utf-8 -*-
##############################################################################
#
#    Author: Guewen Baconnier
#    Copyright 2012 Camptocamp SA
#
#    This program is free software: you can redistribute it and/or modify
#    it under the terms of the GNU Affero General Public License as
#    published by the Free Software Foundation, either version 3 of the
#    License, or (at your option) any later version.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU Affero General Public License for more details.
#
#    You should have received a copy of the GNU Affero General Public License
#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
#
##############################################################################


[docs]class ConnectorException(RuntimeError): """ Base Exception for the connectors """
[docs]class NoConnectorUnitError(ConnectorException): """ No ConnectorUnit has been found """
[docs]class InvalidDataError(ConnectorException): """ Data Invalid """
[docs]class MappingError(ConnectorException): """ An error occurred during a mapping transformation. """
[docs]class JobError(ConnectorException): """ A job had an error """
[docs]class NoSuchJobError(JobError): """ The job does not exist. """
[docs]class NotReadableJobError(JobError): """ The job cannot be read from the storage. """
[docs]class FailedJobError(JobError): """ A job had an error having to be resolved. """
[docs]class RetryableJobError(JobError): """ A job had an error but can be retried. The job will be retried after the given number of seconds. If seconds is empty, it will be retried according to the ``retry_pattern`` of the job or by :const:`connector.queue.job.RETRY_INTERVAL` if nothing is defined. If ``ignore_retry`` is True, the retry counter will not be increased. """ def __init__(self, msg, seconds=None, ignore_retry=False): super(RetryableJobError, self).__init__(msg) self.seconds = seconds self.ignore_retry = ignore_retry
[docs]class NetworkRetryableError(RetryableJobError): """ A network error caused the failure of the job, it can be retried later. """
[docs]class NothingToDoJob(JobError): """ The Job has nothing to do. """
[docs]class NoExternalId(RetryableJobError): """ No External ID found, it can be retried later. """
[docs]class IDMissingInBackend(JobError): """ The ID does not exist in the backend """
[docs]class ManyIDSInBackend(JobError): """Unique key exists many times in backend"""
[docs]class ChannelNotFound(ConnectorException): """ A channel could not be found """