From 3f96543202a8a1052609cc5654b94f94e7b038d3 Mon Sep 17 00:00:00 2001 From: Serhii Dimchenko Date: Thu, 7 Sep 2023 10:05:44 +0200 Subject: [PATCH] Try add comment --- dbt/adapters/athena/impl.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dbt/adapters/athena/impl.py b/dbt/adapters/athena/impl.py index 275f68d7..c301acaf 100755 --- a/dbt/adapters/athena/impl.py +++ b/dbt/adapters/athena/impl.py @@ -952,9 +952,9 @@ 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) + conn.execute(sql, catch_partitions_limit=True) except OperationalError as e: LOGGER.debug(f"CAUGHT EXCEPTION: {e}") if "TOO_MANY_OPEN_PARTITIONS" in str(e):