From fcfa7cf4b65a737af9ff10c827c506f41147e9aa Mon Sep 17 00:00:00 2001 From: Serhii Dimchenko Date: Thu, 7 Sep 2023 09:51:56 +0200 Subject: [PATCH] Try add comment --- dbt/adapters/athena/impl.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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: