from airflow import DAG
from airflow.providers.postgres.operators.postgres import PostgresOperator
from datetime import datetime

with DAG(
    dag_id="clickhouse_list_tables_1",
    start_date=datetime(2025, 1, 1),
    schedule_interval=None,
    catchup=False,
) as dag:

    list_tables = PostgresOperator(
        task_id="list_tables",
        postgres_conn_id="clickhouse_db",
        sql="SELECT 1;"
    )