diff --git a/CHANGELOG.md b/CHANGELOG.md index c38f4bc45..efc2a71ef 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,7 @@ +## [1.4.6] + +* **fix: normalize teradata column names to lowercase for Enterprise compatibility** + ## [1.4.5] * **fix: add capability to use opensearch serverless** diff --git a/unstructured_ingest/__version__.py b/unstructured_ingest/__version__.py index 16cc08681..4a98c89f5 100644 --- a/unstructured_ingest/__version__.py +++ b/unstructured_ingest/__version__.py @@ -1 +1 @@ -__version__ = "1.4.5" # pragma: no cover +__version__ = "1.4.6" # pragma: no cover diff --git a/unstructured_ingest/processes/connectors/sql/teradata.py b/unstructured_ingest/processes/connectors/sql/teradata.py index 75bd8ca91..a6509dff0 100644 --- a/unstructured_ingest/processes/connectors/sql/teradata.py +++ b/unstructured_ingest/processes/connectors/sql/teradata.py @@ -154,7 +154,7 @@ def query_db(self, file_data: SqlBatchFileData) -> tuple[list[tuple], list[str]] logger.debug(f"running query: {query}\nwith values: {ids}") cursor.execute(query, ids) rows = cursor.fetchall() - columns = [col[0] for col in cursor.description] + columns = [col[0].lower() for col in cursor.description] return rows, columns @@ -202,7 +202,7 @@ def get_table_columns(self) -> list[str]: if self._columns is None: with self.get_cursor() as cursor: cursor.execute(f'SELECT TOP 1 * FROM "{self.upload_config.table_name}"') - self._columns = [desc[0] for desc in cursor.description] + self._columns = [desc[0].lower() for desc in cursor.description] return self._columns def delete_by_record_id(self, file_data: FileData) -> None: