fix: add stream name for source-file (#45)

ollionorg · Sep 2, 2024 · d4bcd49 · d4bcd49
1 parent 674edfa
commit d4bcd49
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/airbyte-integrations/connectors/source-file/metadata.yaml b/airbyte-integrations/connectors/source-file/metadata.yaml
@@ -10,7 +10,7 @@ data:
   connectorSubtype: file
   connectorType: source
   definitionId: 778daa7c-feaf-4db6-96f3-70fd645acc77
-  dockerImageTag: 0.3.17-v1.0.1
+  dockerImageTag: 0.3.17-v1.0.2
   dockerRepository: airbyte/source-file
   documentationUrl: https://docs.airbyte.com/integrations/sources/file
   githubIssueLabel: source-file

diff --git a/airbyte-integrations/connectors/source-file/source_file/client.py b/airbyte-integrations/connectors/source-file/source_file/client.py
@@ -307,6 +307,8 @@ def reader_class(self):
     @property
     def stream_name(self) -> str:
         file = urlparse(self._url)
+        if self._dataset_name:
+            return f"file_{self._dataset_name}"
         return f"file_{self._provider['storage']}_{file.path.split('/')[-1]}"
 
     def load_nested_json_schema(self, fp) -> dict: