schema = Schema.from_dict(schema_dict)
mdata = field_metadata[stream_name]
key_properties = None
- for md in mdata:
- table_key_properties = md.get('metadata', {}).get('table-key-properties')
+ for mdt in mdata:
+ table_key_properties = mdt.get('metadata', {}).get('table-key-properties')
if table_key_properties:
key_properties = table_key_properties
-
+
catalog.streams.append(CatalogEntry(
stream=stream_name,
tap_stream_id=stream_name,