update execute_complete

apache · May 12, 2024 · 0698252 · 0698252
1 parent 7c2dc0f
commit 0698252
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/airflow/providers/databricks/operators/databricks.py b/airflow/providers/databricks/operators/databricks.py
@@ -1091,8 +1091,6 @@ def execute_complete(self, context: dict | None, event: dict) -> None:
             )
         if not run_state.is_successful:
             raise AirflowException(
-                "Task failed. Final state %s. Reason: %s",
-                run_state.result_state,
-                run_state.state_message,
+                f"Task failed. Final state {run_state.result_state}. Reason: {run_state.state_message}"
             )
         self.log.info("Task succeeded. Final state %s.", run_state.result_state)