ddadminandClaude Fable 5
f5dee26eda
- Зачем:
- режим кормления стенда порциями: менти триггерит «следующий день»,
видит полный цикл DWH за один шаг (задача 13, вариант 2 — генерация
от слепка T_end).
- Что:
- новый ограниченный режим next-day: восстановление мира из state,
генерация ровно [T_end, T_end+24h), публикация данные -> state ->
манифест (манифест — точка фиксации, автоотката нет).
- операция next-day в DAG generator_control: своя предпроверка границы
вместо clean-guard, идемпотентность через параметр expected_t_end.
- цепочка границ — накопительное поле boundaries в манифесте, старый
формат читается как [T0, T_end]; импорт не изменён.
- новая проверка цепочки (make generated-history-chain-check): непарные
счётчики и однородность по каждой границе, явный статус нулевого
стыка, хвост за границей по всем четырём топикам, литералы в UTC
с микросекундами.
- документация OPERATIONS.md: глагол, предпроверка, восстановление
после сбоя, ограничение retention; в задаче 13 — решения двух слепых
ревью постановки и кода с аргументами отклонений.
- Проверка:
- make test: 204 теста генератора + 31 контракт корня, зелёные.
- make generated-history-chain-check: зелёный, 2 внутренние границы,
непарные счётчики нулевые; учебный цикл: DM 322 -> 10026 -> 19196
за два next-day подряд.
- make generated-history-runtime-check (регрессия задачи 20): зелёный.
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
92 lines
3.5 KiB
Python
92 lines
3.5 KiB
Python
"""
|
|
Тесты профилей и глаголов запуска генератора.
|
|
"""
|
|
|
|
from datetime import datetime, timezone
|
|
|
|
|
|
def test_duration_2d_sets_model_t_end_from_t0():
|
|
"""Длительность 2d считается от T0 без ручного GEN_MODEL_T_END."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
env = build_launch_env("backfill", profile_name="ci", duration="2d")
|
|
|
|
assert env["GEN_MODEL_T0"] == "2026-01-01T00:00:00+00:00"
|
|
assert env["GEN_MODEL_T_END"] == "2026-01-03T00:00:00+00:00"
|
|
|
|
|
|
def test_daily_wave_profile_uses_two_days_by_default():
|
|
"""Профиль daily-wave даёт историю с суточной волной."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
env = build_launch_env("backfill", profile_name="daily-wave")
|
|
|
|
assert env["GEN_LAUNCH_PROFILE"] == "daily-wave"
|
|
assert env["GEN_HISTORY_DURATION"] == "2d"
|
|
assert env["GEN_MODEL_T_END"] == "2026-01-03T00:00:00+00:00"
|
|
assert env["GEN_MODEL_TIME_SPEED"] == "60"
|
|
assert env["GEN_TICK_SECONDS"] == "1"
|
|
|
|
|
|
def test_backfill_verb_maps_to_existing_low_level_flags():
|
|
"""Глагол backfill оставляет прежнюю механику запуска под капотом."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
env = build_launch_env("backfill", profile_name="ci")
|
|
|
|
assert env["GEN_RUN_MODE"] == "backfill"
|
|
assert env["GEN_STATE_RESET"] == "true"
|
|
|
|
|
|
def test_continue_and_reset_verbs_map_to_existing_low_level_flags():
|
|
"""Глаголы continue и reset задают только старый контракт state."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
continue_env = build_launch_env("continue", profile_name="ci")
|
|
reset_env = build_launch_env(
|
|
"reset",
|
|
profile_name="ci",
|
|
overrides={"GEN_MODEL_T_END": "2026-01-09T00:00:00+00:00"},
|
|
)
|
|
|
|
assert continue_env["GEN_RUN_MODE"] == "live"
|
|
assert continue_env["GEN_STATE_RESET"] == "false"
|
|
assert continue_env["GEN_MODEL_T_END"] == "2026-01-01T06:00:00+00:00"
|
|
assert reset_env["GEN_RUN_MODE"] == "live"
|
|
assert reset_env["GEN_STATE_RESET"] == "true"
|
|
assert "GEN_MODEL_T_END" not in reset_env
|
|
|
|
|
|
def test_next_day_verb_restores_snapshot_without_reset():
|
|
"""Глагол next-day включает отдельный ограниченный режим от текущей границы."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
env = build_launch_env(
|
|
"next-day",
|
|
profile_name="ci",
|
|
overrides={
|
|
"GEN_MODEL_T0": "2026-01-01T00:00:00+00:00",
|
|
"GEN_MODEL_T_END": "2026-01-03T00:00:00+00:00",
|
|
},
|
|
)
|
|
|
|
assert env["GEN_RUN_MODE"] == "next-day"
|
|
assert env["GEN_STATE_RESET"] == "false"
|
|
assert env["GEN_MODEL_T_END"] == "2026-01-03T00:00:00+00:00"
|
|
|
|
|
|
def test_ci_profile_keeps_previous_default_backfill_window():
|
|
"""CI-профиль сохраняет прежний 6-часовой проверочный запуск."""
|
|
from clickstream_generator.launch import build_launch_env
|
|
|
|
env = build_launch_env("backfill", profile_name="ci")
|
|
|
|
t0 = datetime.fromisoformat(env["GEN_MODEL_T0"])
|
|
t_end = datetime.fromisoformat(env["GEN_MODEL_T_END"])
|
|
assert t0 == datetime(2026, 1, 1, 0, 0, tzinfo=timezone.utc)
|
|
assert (t_end - t0).total_seconds() == 6 * 60 * 60
|
|
assert env["GEN_MODEL_TIME_SPEED"] == "1"
|
|
assert env["GEN_TICK_SECONDS"] == "60"
|
|
assert env["GEN_LAMBDA_BASE_PER_MIN"] == "60"
|
|
assert env["GEN_JITTER_PCT"] == "0"
|