File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -154,7 +154,7 @@ def _replace_parent_streams_with_refs(self) -> None:
154154 with a $ref to the correct stream index.
155155 """
156156 streams = self ._normalized_manifest .get (STREAMS_TAG , [])
157-
157+
158158 # Build a hash-to-index mapping for O(1) lookups
159159 stream_hash_to_index = {}
160160 for idx , stream in enumerate (streams ):
@@ -187,7 +187,9 @@ def _replace_parent_streams_with_refs(self) -> None:
187187 if stream_ref is not None and isinstance (stream_ref , dict ):
188188 stream_ref_hash = self ._hash_object (stream_ref )
189189 if stream_ref_hash in stream_hash_to_index :
190- parent_config ["stream" ] = {"$ref" : f"#/streams/{ stream_hash_to_index [stream_ref_hash ]} " }
190+ parent_config ["stream" ] = {
191+ "$ref" : f"#/streams/{ stream_hash_to_index [stream_ref_hash ]} "
192+ }
191193
192194 def _clean_dangling_fields (self ) -> None :
193195 """
You can’t perform that action at this time.
0 commit comments