faust.exceptions

Faust exceptions.

exception faust.exceptions.FaustError[source]

Base-class for all Faust exceptions.

exception faust.exceptions.FaustWarning[source]

Base-class for all Faust warnings.

exception faust.exceptions.NotReady[source]

Service not started.

exception faust.exceptions.AlreadyConfiguredWarning[source]

Trying to configure app after configuration accessed.

exception faust.exceptions.ImproperlyConfigured[source]

The library is not configured/installed correctly.

exception faust.exceptions.DecodeError[source]

Error while decoding/deserializing message key/value.

exception faust.exceptions.KeyDecodeError[source]

Error while decoding/deserializing message key.

exception faust.exceptions.ValueDecodeError[source]

Error while decoding/deserializing message value.

exception faust.exceptions.SameNode[source]

Exception raised by router when data is located on same node.

exception faust.exceptions.ProducerSendError[source]

Error while sending attached messages prior to commit.

exception faust.exceptions.ConsumerNotStarted[source]

Error trying to perform operation on consumer not started.

exception faust.exceptions.PartitionsMismatch[source]

Number of partitions between related topics differ.