Fixing list_schemas so that we stop trying to create schemas that exi…

…st (#529)
databricks · Dec 8, 2023 · bb4abb4 · bb4abb4
2 parents 004ca00 + e67f78d
commit bb4abb4
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/dbt/adapters/databricks/connections.py b/dbt/adapters/databricks/connections.py
@@ -1179,12 +1179,19 @@ def _execute_cursor(
                     cursor.close()
 
     def list_schemas(self, database: str, schema: Optional[str] = None) -> Table:
+        database = database.strip("`")
+        if schema:
+            schema = schema.strip("`")
         return self._execute_cursor(
             f"GetSchemas(database={database}, schema={schema})",
             lambda cursor: cursor.schemas(catalog_name=database, schema_name=schema),
         )
 
     def list_tables(self, database: str, schema: str, identifier: Optional[str] = None) -> Table:
+        database = database.strip("`")
+        schema = schema.strip("`")
+        if identifier:
+            identifier = identifier.strip("`")
         return self._execute_cursor(
             f"GetTables(database={database}, schema={schema}, identifier={identifier})",
             lambda cursor: cursor.tables(