s6.app._track_runtimeΒΆ

Worker-owned runtime loop for s6 track frame processing.

class s6.app._track_runtime.TrackCommand(command: CommandSet, payload: Any = None, command_id: str | None = None)

Bases: object

Command envelope consumed by TrackRuntime.

command: CommandSet
payload: Any = None
command_id: str | None = None
class s6.app._track_runtime.TrackState(source_kind: str, playback_state: PlaybackMode, frame_serial: int, frame_length: int, last_rendered_frame: int, is_recording: bool, status_message: str | None = None, pipeline_fps: float | None = None, pipeline_latency_ms: float | None = None)

Bases: object

Authoritative playback state emitted with each UI frame.

source_kind: str
playback_state: PlaybackMode
frame_serial: int
frame_length: int
last_rendered_frame: int
is_recording: bool
status_message: str | None = None
pipeline_fps: float | None = None
pipeline_latency_ms: float | None = None
class s6.app._track_runtime.TrackFrameMessage(context: Dict[str, Any], state: TrackState, command_id: str | None = None)

Bases: object

Processed frame plus the worker state that produced it.

context: Dict[str, Any]
state: TrackState
command_id: str | None = None
class s6.app._track_runtime.TrackRuntime(context_generator: ContextGenerator)

Bases: object

Own command ordering, playback state, pipeline execution, and output.

PIPELINE_FPS_WINDOW = 30
run(*, queue=None, command_queue=None, shutdown_event=None, queue_payload_mode: str = 'context') None

Run the controller loop until the source ends or shutdown is requested.