diff --git a/clickhouse_dag.py b/clickhouse_dag.py index c04ee0c..d495e73 100644 --- a/clickhouse_dag.py +++ b/clickhouse_dag.py @@ -11,10 +11,13 @@ with DAG( list_tables = SimpleHttpOperator( task_id="list_tables", - http_conn_id="clickhouse_http", # Connection в Airflow + http_conn_id="clickhouse_http", endpoint="/", method="POST", data={"query": "SHOW TABLES"}, headers={"Content-Type": "application/x-www-form-urlencoded"}, - log_response=True, # покажет результат в логах Airflow - ) + log_response=True, + retries=0, + retry_delay=0, + timeout=10, + ) \ No newline at end of file