diff --git a/clickhouse_dag.py b/clickhouse_dag.py index 04f45d9..871cc94 100644 --- a/clickhouse_dag.py +++ b/clickhouse_dag.py @@ -1,23 +1,18 @@ 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", + http_conn_id="clickhouse_http", # Connection в Airflow endpoint="/", method="POST", data={"query": "SHOW TABLES"}, headers={"Content-Type": "application/x-www-form-urlencoded"}, - log_response=True, - retries=0, - retry_delay=0, - timeout=10 + log_response=True, # покажет результат в логах Airflow ) \ No newline at end of file