File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -124,16 +124,17 @@ def _reference_schemas(manifest: ManifestType) -> None:
124124 """
125125
126126 # create the ref tag to each stream in the manifest
127- if STREAMS_TAG in manifest :
127+ if STREAMS_TAG in manifest . keys () :
128128 for stream in manifest [STREAMS_TAG ]:
129129 stream_name = stream .get ("name" )
130130 # reference the stream schema for the stream to where it's storred
131- if stream_name in manifest [SCHEMAS_TAG ].keys ():
132- stream [SCHEMA_LOADER_TAG ][SCHEMA_TAG ] = _create_schema_ref (stream_name )
133- else :
134- raise ManifestDeduplicationException (
135- f"Stream { stream_name } not found in `schemas`. Please check the manifest."
136- )
131+ if SCHEMAS_TAG in manifest .keys ():
132+ if stream_name in manifest [SCHEMAS_TAG ].keys ():
133+ stream [SCHEMA_LOADER_TAG ][SCHEMA_TAG ] = _create_schema_ref (stream_name )
134+ else :
135+ raise ManifestDeduplicationException (
136+ f"Stream { stream_name } not found in `schemas`. Please check the manifest."
137+ )
137138
138139
139140def _replace_duplicates_with_refs (manifest : ManifestType , duplicates : DuplicatesType ) -> None :
You can’t perform that action at this time.
0 commit comments