verify_streaming

Прогон validate через онлайн-контур (build_features_online + CatBoost-ансамбль).

Задача — доказать, что submission.csv можно воспроизвести стриминг-путём, а не только батчем. Для каждой точки из validate/points.csv:

1. фильтруем validate/traffic.csv по event_time ≤ T и tr_id (эмулируем историю пингов до T),

2. берём слайс validate/schedule_plan.csv по tr_id,

3. вызываем features/from_stream.build_features_online и предиктим ансамблем.

Затем сравниваем с текущим submission.csv поточечно. Если max|Δ| < 1e-3 сек — контур эквивалентен батчу и решение честно работает в стриминг-режиме.

Запуск:

python ml/src/verify_streaming.py --dataset ./dataset --submission ./submission.csv

Functions

load_models(art)
main()

verify_streaming.load_models(art: Path) → tuple[list[catboost.CatBoostRegressor], dict]

verify_streaming.main() → None