bugfix/fix databricks volumes table uploader precheck (#431)

rbiseck3 · web-flow · commit cb7a53a44f8b · 2025-03-20T08:51:28.000-04:00
* fix databricks volumes table uploader precheck

* update changelog

* drop print statement

* modify version
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,6 +1,9 @@
-## 0.5.16
+## 0.5.16-dev0
 
-Zendesk fix for debug
+### Fixes 
+
+* **Fix databricks volumes table uploader precheck**
+* **Zendesk fix for debug**
 
 ## 0.5.15
 
diff --git a/unstructured_ingest/__version__.py b/unstructured_ingest/__version__.py
@@ -1 +1 @@
-__version__ = "0.5.16"  # pragma: no cover
+__version__ = "0.5.16-dev0"  # pragma: no cover
diff --git a/unstructured_ingest/v2/processes/connectors/databricks/volumes_table.py b/unstructured_ingest/v2/processes/connectors/databricks/volumes_table.py
@@ -61,7 +61,7 @@ def precheck(self) -> None:
                         self.upload_config.database, ", ".join(databases)
                     )
                 )
-            cursor.execute("SHOW TABLES")
+            cursor.execute(f"SHOW TABLES IN {self.upload_config.database}")
             table_names = [r[1] for r in cursor.fetchall()]
             if self.upload_config.table_name not in table_names:
                 raise ValueError(

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ def precheck(self) -> None:`
`61`	`61`	`self.upload_config.database, ", ".join(databases)`
`62`	`62`	`)`
`63`	`63`	`)`
`64`		`- cursor.execute("SHOW TABLES")`
	`64`	`+ cursor.execute(f"SHOW TABLES IN {self.upload_config.database}")`
`65`	`65`	`table_names = [r[1] for r in cursor.fetchall()]`
`66`	`66`	`if self.upload_config.table_name not in table_names:`
`67`	`67`	`raise ValueError(`