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;" + )