from airflow import DAG
from airflow.providers.clickhouse.operators.clickhouse import ClickHouseOperator
from airflow.utils.dates import days_ago

default_args = {
    "owner": "airflow",
}

with DAG(
    dag_id="test_clickhouse_select",
    default_args=default_args,
    description="Simple SELECT 1 in ClickHouse",
    start_date=days_ago(1),
    schedule_interval=None,      # запуск только вручную
    catchup=False,
    tags=["clickhouse"],
) as dag:

    select_1 = ClickHouseOperator(
        task_id="select_one",
        clickhouse_conn_id="my_clickhouse_provider",  # ваш Connection ID
        sql="SELECT 1",
    )