We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents b2789dc + fcffe8e commit 1aed460Copy full SHA for 1aed460
src/webapp/databricks.py
@@ -8,6 +8,7 @@
8
Format,
9
ExecuteStatementRequestOnWaitTimeout,
10
Disposition,
11
+ StatementState,
12
)
13
from .config import databricks_vars, gcs_vars
14
from .utilities import databricksify_inst_name, SchemaType
@@ -241,7 +242,7 @@ def fetch_table_data(
241
242
raise ValueError(f"Databricks API call failed: {e}")
243
244
# Check if the query execution was successful
- if response.status.state != "SUCCEEDED":
245
+ if response.status.state != StatementState.SUCCEEDED:
246
error_message = (
247
response.status.error.message
248
if response.status.error
0 commit comments