diff --git a/dags/test_clickhouse.py b/dags/test_clickhouse.py index 7a0c630..17d9808 100644 --- a/dags/test_clickhouse.py +++ b/dags/test_clickhouse.py @@ -1,4 +1,18 @@ -"""Сквозная проверка подключения Airflow к кластеру ClickHouse.""" +"""Сквозная проверка связности Airflow с кластером ClickHouse. + +Тест проверяет: + +- до запуска служебных таблиц нет ни на одной ноде; +- после создания на обеих лежит ожидаемая пара движков; +- маркер запуска вставлен в локальную таблицу ноды 1 и найден там ровно одной + строкой; +- нода 2 читает этот маркер через Distributed и видит его на первом шарде; +- после уборки таблиц не осталось ни на одной ноде. + +Этот тест — не образец ETL. Он ходит ON CLUSTER на каждом шаге, заводит и +сносит собственные служебные таблицы за один запуск и читает ноду 2 запросом +remote(): это приёмы проверки связности, а не загрузки данных. +""" from __future__ import annotations