stream_manager

sqllocks_spindle.engine.stream_manager

Classes

StreamManager

Manages background streaming jobs. One instance per process (singleton).

Methods:

start(run_fn)

Start a background streaming job. run_fn(state) is called in a daemon thread.

stop(stream_id)

Signal a stream to stop and wait up to 5 s for it to finish.

Returns:

Type	Description
bool | None	None — stream_id was not found.
bool | None	True — stream stopped cleanly within the timeout.
bool | None	False — stream did not finish within the timeout (still alive).