Reformat

databricks · Jan 22, 2024 · c656b0f · c656b0f
1 parent 8a9ab5a
commit c656b0f
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/dbt/adapters/databricks/connections.py b/dbt/adapters/databricks/connections.py
@@ -1503,7 +1503,9 @@ def _get_pipeline_state(session: Session, host: str, pipeline_id: str) -> dict:
 
     response = session.get(pipeline_url)
     if response.status_code != 200:
-        raise dbt.exceptions.DbtRuntimeError(f"Error getting pipeline info for {pipeline_id}: {response.text}")
+        raise dbt.exceptions.DbtRuntimeError(
+            f"Error getting pipeline info for {pipeline_id}: {response.text}"
+        )
 
     return response.json()
 
@@ -1529,7 +1531,9 @@ def _get_update_error_msg(session: Session, host: str, pipeline_id: str, update_
     events_url = f"https://{host}/api/2.0/pipelines/{pipeline_id}/events"
     response = session.get(events_url)
     if response.status_code != 200:
-        raise dbt.exceptions.DbtRuntimeError(f"Error getting pipeline event info for {pipeline_id}: {response.text}")
+        raise dbt.exceptions.DbtRuntimeError(
+            f"Error getting pipeline event info for {pipeline_id}: {response.text}"
+        )
 
     events = response.json().get("events", [])
     update_events = [