Source code for faust.exceptions

"""Faust exceptions."""

__all__ = [
    'FaustError',
    'ImproperlyConfigured',
    'DecodeError',
    'KeyDecodeError',
    'ValueDecodeError',
]



[docs]class FaustError(Exception):
    """Base-class for all Faust exceptions."""




[docs]class ImproperlyConfigured(FaustError):
    """The library is not configured/installed correctly."""




[docs]class DecodeError(FaustError):
    """Error while decoding/deserializing message key/value."""




[docs]class KeyDecodeError(DecodeError):
    """Error while decoding/deserializing message key."""




[docs]class ValueDecodeError(DecodeError):
    """Error while decoding/deserializing message value."""



class SameNode(FaustError):
    """Exception raised by router when data is located on same node."""


class ProducerSendError(FaustError):
    """Error while sending attached messages prior to commit"""