From d831c740c25735d0dffb8ad6e432c42940e74f92 Mon Sep 17 00:00:00 2001
From: Alex <123@mail.ru>
Date: Tue, 23 Sep 2025 12:43:27 +0300
Subject: [PATCH] add dag for clickhouse

---
 clickhouse_dag_new.py | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100644 clickhouse_dag_new.py

diff --git a/clickhouse_dag_new.py b/clickhouse_dag_new.py
new file mode 100644
index 0000000..9385c98
--- /dev/null
+++ b/clickhouse_dag_new.py
@@ -0,0 +1,16 @@
+from airflow import DAG
+from airflow.providers.postgres.operators.postgres import PostgresOperator
+from datetime import datetime
+
+with DAG(
+    dag_id="clickhouse_list_tables",
+    start_date=datetime(2025, 1, 1),
+    schedule_interval=None,
+    catchup=False,
+) as dag:
+
+    list_tables = PostgresOperator(
+        task_id="list_tables",
+        postgres_conn_id="clickhouse_http",
+        sql="SELECT 1;"
+    )