remove sftp indexer run override #631

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged

potter-potter merged 2 commits into main from potter/sftp-indexer

Jan 29, 2026

+6 −13

CHANGELOG.md

-Original file line number
+Diff line change
@@ -1,3 +1,7 @@
+    ## [1.2.38]
+    * **fix: remove sftp indexer run override
     ## [1.2.37]
     * **fix: sftp protocol needs default**
@@ Expand Down @@

unstructured_ingest/__version__.py

unstructured_ingest/processes/connectors/fsspec/sftp.py

-Original file line number
+Diff line change
@@ Expand Up / @@ -12,7 +12,7 @@ @@
     from pydantic import Field, Secret
-    from unstructured_ingest.data_types.file_data import FileData, FileDataSourceMetadata
+    from unstructured_ingest.data_types.file_data import FileDataSourceMetadata
     from unstructured_ingest.processes.connector_registry import (
         DestinationRegistryEntry,
         SourceRegistryEntry,
@@ Expand Down Expand Up / @@ -149,17 +149,6 @@ def precheck(self) -> None: @@
                 )
                 raise self.wrap_error(e=e)
-        def run(self, **kwargs: Any) -> Generator[FileData, None, None]:
-            for file in super().run(**kwargs):
-                new_identifier = (
-                    f"sftp://"
-                    f"{self.connection_config.host}:"
-                    f"{self.connection_config.port}/"
-                    f"{file.identifier}"
-                )
-                file.identifier = new_identifier
-                yield file
         def get_metadata(self, file_info: dict) -> FileDataSourceMetadata:
             path = file_info["name"]
             date_created = str(file_info.get("time").timestamp()) if "time" in file_info else None
@@ Expand Down @@

Provide feedback