jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Revert "move dict()"

Browse Source 
This reverts commit fa347a8236.
This commit is contained in:
Alexandre Girard
2023-06-30 07:52:48 -07:00
parent fa347a8236
commit c9237df2e4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
airbyte-cdk/python/airbyte_cdk/sources/file_based/stream/default_file_based_stream.py
View File

@@ -106,13 +106,13 @@ class DefaultFileBasedStream(AbstractFileBasedStream, IncrementalMixin):
self.ab_last_mod_col: {"type": "string"},
self.ab_file_name_col: {"type": "string"},
}
schema = self._get_raw_json_schema()
schema = dict(self._get_raw_json_schema())
schema["properties"] = {**extra_fields, **schema.get("properties", {})}
return schema
def _get_raw_json_schema(self) -> Dict[str, Any]:
def _get_raw_json_schema(self) -> Mapping[str, Any]:
if self.config.input_schema:
type_mapping = dict(self.config.input_schema)
type_mapping = self.config.input_schema
else:
files = self.list_files()
max_n_files_for_schema_inference = self._discovery_policy.max_n_files_for_schema_inference