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:
objectCommand 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:
objectAuthoritative 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:
objectProcessed 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:
objectOwn 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.