Skip to content

Commit 07a948c

Browse files
committed
Allow disabling .json extension in fsspec connector uploads
1 parent 0ed1433 commit 07a948c

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

unstructured_ingest/__version__.py

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

unstructured_ingest/processes/connectors/fsspec/fsspec.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,8 @@ def get_upload_path(self, file_data: FileData) -> Path:
346346
upload_path = Path(
347347
self.upload_config.path_without_protocol
348348
) / file_data.source_identifiers.relative_path.lstrip("/")
349-
updated_upload_path = upload_path.parent / f"{upload_path.name}.json"
349+
suffix = os.environ.get("UNSTRUCTURED_INGEST_UPLOAD_APPEND_SUFFIX", ".json")
350+
updated_upload_path = upload_path.parent / f"{upload_path.name}{suffix}"
350351
return updated_upload_path
351352

352353
def run(self, path: Path, file_data: FileData, **kwargs: Any) -> None:

0 commit comments

Comments
 (0)