from airflow import DAG
from airflow.providers.http.operators.http import SimpleHttpOperator
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 = SimpleHttpOperator(
        task_id="list_tables",
        http_conn_id="clickhouse_http",
        endpoint="/",
        method="POST",
        data="SHOW TABLES",
        headers={"Content-Type": "text/plain"},
        log_response=True,
    )