faust.exceptions

Faust exceptions.

exception faust.exceptions.FaustError

Base-class for all Faust exceptions.

exception faust.exceptions.FaustWarning

Base-class for all Faust warnings.

exception faust.exceptions.FaustPredicate

Base-class for semi-predicates such as Skip.

exception faust.exceptions.SecurityError

Base-class for security related (high priority) exceptions.

exception faust.exceptions.NotReady

Service not started.

exception faust.exceptions.Skip

Raised in stream processors to skip processing of an event.

exception faust.exceptions.AlreadyConfiguredWarning

Trying to configure app after configuration accessed.

exception faust.exceptions.ImproperlyConfigured

The library is not configured/installed correctly.

exception faust.exceptions.ValidationError(reason: str, *, field: _FieldDescriptorT)

Value passed for model field is not valid.

field: _FieldDescriptorT

exception faust.exceptions.DecodeError

Error while decoding/deserializing message key/value.

exception faust.exceptions.KeyDecodeError

Error while decoding/deserializing message key.

exception faust.exceptions.ValueDecodeError

Error while decoding/deserializing message value.

exception faust.exceptions.SameNode

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

exception faust.exceptions.ProducerSendError

Error while sending attached messages prior to commit.

exception faust.exceptions.ConsumerNotStarted

Error trying to perform operation on consumer not started.

exception faust.exceptions.PartitionsMismatch

Number of partitions between related topics differ.

exception faust.exceptions.ConsistencyError

Persisted table offset is out of sync with changelog topic highwater.