Skip to content

Commit 5d679fa

Browse files
databricks volumes add .json (#198)
1 parent bf81552 commit 5d679fa

File tree

3 files changed

+10
-2
lines changed

3 files changed

+10
-2
lines changed

CHANGELOG.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,9 @@
1+
## 0.2.1-dev0
2+
3+
### Fixes
4+
5+
* **Fix Databricks Volumes file nameing** Add .json to end of upload file.
6+
17
## 0.2.0
28

39
### Enhancements

unstructured_ingest/__version__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "0.2.0" # pragma: no cover
1+
__version__ = "0.2.1-dev0" # pragma: no cover

unstructured_ingest/v2/processes/connectors/databricks/volumes.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,9 @@ def precheck(self) -> None:
166166
raise DestinationConnectionError(f"failed to validate connection: {e}")
167167

168168
def run(self, path: Path, file_data: FileData, **kwargs: Any) -> None:
169-
output_path = os.path.join(self.upload_config.path, file_data.source_identifiers.filename)
169+
output_path = os.path.join(
170+
self.upload_config.path, f"{file_data.source_identifiers.filename}.json"
171+
)
170172
with open(path, "rb") as elements_file:
171173
self.connection_config.get_client().files.upload(
172174
file_path=output_path,

0 commit comments

Comments
 (0)