diff --git a/dbt/adapters/athena/impl.py b/dbt/adapters/athena/impl.py
index a435f1cb..275f68d7 100755
--- a/dbt/adapters/athena/impl.py
+++ b/dbt/adapters/athena/impl.py
@@ -949,9 +949,10 @@ def _get_table_input(table: TableTypeDef) -> TableInputTypeDef:
 
     @available
     def run_query_with_partitions_limit_catching(self, sql: str) -> str:
+        sql = self.connections._add_query_comment(sql)
         conn = self.connections.get_thread_connection()
         cursor = conn.handle.cursor()
-        LOGGER.debug(f"Running Athena query:\n{sql}")
+        # LOGGER.debug(f"Running Athena query:\n{sql}")
         try:
             cursor.execute(sql, catch_partitions_limit=True)
         except OperationalError as e: