Skip to content

Commit

Permalink
Try add comment
Browse files Browse the repository at this point in the history
  • Loading branch information
svdimchenko committed Sep 7, 2023
1 parent fcfa7cf commit 3f96543
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dbt/adapters/athena/impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down

0 comments on commit 3f96543

Please sign in to comment.