sink_registry

sqllocks_spindle.engine.sink_registry

Classes

SinkError

Bases: Exception

Raised when one or more sinks fail during write_chunk.

SinkRegistry

Fan-out coordinator — dispatches each chunk to all registered sinks in parallel.