s6.app.replay

Replay a StructuredDataset over a telemetry WebSocket service.

This script starts a lightweight telemetry service without running any inference. It reads frames from a StructuredDataset directory and streams the context['export'] payload over WebSocket to connected clients.

Usage:

s6 replay /path/to/StructuredDataset [–host 0.0.0.0] [–port 8001] [–repeat] [–hz 10] [–max-queue 128]

Notes: - No inference or additional computation is performed. The dataset’s records

are relayed as-is using the StructuredDataset API directly (no context generators). If a record contains an export key, it will be sent; otherwise, an empty object is sent for export.

• A simple rate limit is applied via --hz and the producer will pause when the queue backlog exceeds --max-queue to avoid unbounded growth.

s6.app.replay.main(argv: list[str] | None = None) → int