diff --git a/clickhouse_dag_new.py b/clickhouse_dag_new.py
index d6e684d..10b1f36 100644
--- a/clickhouse_dag_new.py
+++ b/clickhouse_dag_new.py
@@ -11,6 +11,6 @@ with DAG(
 
     list_tables = PostgresOperator(
         task_id="list_tables",
-        postgres_conn_id="clickhouse_http",
+        postgres_conn_id="clickhouse_db",
         sql="SELECT 1;"
     )