You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@superset.apache.org by mi...@apache.org on 2025/03/25 18:46:24 UTC
(superset) 04/15: fix(sqllab): Pass query_id as kwarg so backoff can see it (#32774)
This is an automated email from the ASF dual-hosted git repository.
michaelsmolina pushed a commit to branch 5.0
in repository https://gitbox.apache.org/repos/asf/superset.git
commit db2b4cc297f0314c80c729e76db7d73efd55aaf6
Author: Antonio Rivero <38...@users.noreply.github.com>
AuthorDate: Thu Mar 20 18:46:31 2025 +0100
fix(sqllab): Pass query_id as kwarg so backoff can see it (#32774)
(cherry picked from commit 01801e3c36571fd27c6238ccf8fc535461bfdb6f)
---
superset/sql_lab.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/superset/sql_lab.py b/superset/sql_lab.py
index 25ac9a5c5c..8ba985701d 100644
--- a/superset/sql_lab.py
+++ b/superset/sql_lab.py
@@ -193,7 +193,7 @@ def get_sql_results( # pylint: disable=too-many-arguments
except Exception as ex: # pylint: disable=broad-except
logger.debug("Query %d: %s", query_id, ex)
stats_logger.incr("error_sqllab_unhandled")
- query = get_query(query_id)
+ query = get_query(query_id=query_id)
return handle_query_error(ex, query)
@@ -423,7 +423,7 @@ def execute_sql_statements( # noqa: C901
# only asynchronous queries
stats_logger.timing("sqllab.query.time_pending", now_as_float() - start_time)
- query = get_query(query_id)
+ query = get_query(query_id=query_id)
payload: dict[str, Any] = {"query_id": query_id}
database = query.database
db_engine_spec = database.db_engine_spec