Этап 5: Airflow — etl_pipeline #7

New Issue

2026-07-30T16:41:40+03:00

ddmitry commented

2026-07-30 16:41:40 +03:00

Part of #1

Цель этапа: перевести пересчёт слоёв под Airflow — DAG etl_pipeline с переобработкой по дневным партициям и ожиданием дневного батча заказов.

Спека: docs/specs/2026-07-30-stand-v2-realism.md, раздел 7.

DAG'и пишутся под API Airflow 3 (Datasets переименованы в Assets); операторы и сенсоры перед написанием проверить через Context7 — образцы из v1 написаны под Airflow 2 и переносятся не буквально.

Дочерние тикеты

Дочерние тикеты будут нарезаны при входе в этап (по мастер-спеке).

Part of #1 Цель этапа: перевести пересчёт слоёв под Airflow — DAG `etl_pipeline` с переобработкой по дневным партициям и ожиданием дневного батча заказов. Спека: docs/specs/2026-07-30-stand-v2-realism.md, раздел 7. DAG'и пишутся под API Airflow 3 (Datasets переименованы в Assets); операторы и сенсоры перед написанием проверить через Context7 — образцы из v1 написаны под Airflow 2 и переносятся не буквально. ## Дочерние тикеты Дочерние тикеты будут нарезаны при входе в этап (по мастер-спеке).

~~ddmitry referenced this issue 2026-07-30 16:41:41 +03:00~~

Этап 6: расхождения B+D, опоздания, счётчики манифеста #8

ddmitry referenced this issue

2026-07-30 16:51:21 +03:00

Карта: боевой реализм стенда #1

ddmitry added a new dependency 2026-07-30 16:51:38 +03:00

#6 Этап 4: трансформации и витрины, сверка A+C

ddmitry added a new dependency 2026-07-30 16:51:39 +03:00

#8 Этап 6: расхождения B+D, опоздания, счётчики манифеста

ddmitry referenced this issue

2026-07-31 09:32:15 +03:00

Пробные DAG: test_clickhouse и test_kafka вместо демонстрационного #18