From 9474597bc1c872e7afdd79cfd68234fd94764ad9 Mon Sep 17 00:00:00 2001 From: airflow Date: Wed, 24 Sep 2025 06:35:42 +0400 Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D1=82?= =?UTF-8?q?=D1=8C=20test=5Fclickhouse=5Fdag.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- test_clickhouse_dag.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) create mode 100644 test_clickhouse_dag.py diff --git a/test_clickhouse_dag.py b/test_clickhouse_dag.py new file mode 100644 index 0000000..7852421 --- /dev/null +++ b/test_clickhouse_dag.py @@ -0,0 +1,16 @@ +from airflow import DAG +from airflow.providers.clickhouse.hooks.clickhouse import ClickHouseHook +from airflow.operators.python import PythonOperator +from datetime import datetime + +def test_conn(): + hook = ClickHouseHook(clickhouse_conn_id="my_clickhouse_provider") + hook.run("SELECT 1") + +with DAG( + dag_id="test_clickhouse_dag", + start_date=datetime(2024, 1, 1), + schedule=None, + catchup=False, +) as dag: + PythonOperator(task_id="check_clickhouse", python_callable=test_conn)