errors

Public exception types raised by the Arrakis client.

EndpointStalledError

Bases: RuntimeError

A live endpoint delivered nothing for longer than its latency contract allows; the connection is presumed dead.

A dead TCP connection can park a DoGet read for many minutes (or forever, on a quiet stream) without an error, while the muxer gap-fills the endpoint's channels indefinitely -- this error is how that silent failure surfaces to the consumer.

PublishError

Bases: RuntimeError

The broker rejected or failed delivery of published messages.

Raised from the delivery reports collected during :meth:arrakis.publish.Publisher.publish -- without them, a block whose messages fail delivery (an unwritable partition, a message past its timeout) would be dropped silently.