Skip to content

Commit

Permalink
Disable flag
Browse files Browse the repository at this point in the history
  • Loading branch information
hsyyid authored Nov 17, 2023
1 parent e945c3b commit e5251ea
Showing 1 changed file with 9 additions and 8 deletions.
17 changes: 9 additions & 8 deletions tap_hubspot_beta/tap.py
Original file line number Diff line number Diff line change
Expand Up @@ -130,14 +130,15 @@ def catalog_dict(self) -> dict:
The tap's catalog as a dict
"""
catalog = super().catalog_dict
streams = self.streams
for stream in catalog["streams"]:
stream_class = streams[stream["tap_stream_id"]]
stream["stream_meta"] = {}
if hasattr(stream_class, "load_fields_metadata"):
stream_class.load_fields_metadata()
for field in stream["schema"]["properties"]:
stream["schema"]["properties"][field]["field_meta"] = stream_class.fields_metadata.get(field, {})
if self.config.get("catalog_metadata", False):
streams = self.streams
for stream in catalog["streams"]:
stream_class = streams[stream["tap_stream_id"]]
stream["stream_meta"] = {}
if hasattr(stream_class, "load_fields_metadata"):
stream_class.load_fields_metadata()
for field in stream["schema"]["properties"]:
stream["schema"]["properties"][field]["field_meta"] = stream_class.fields_metadata.get(field, {})
return catalog


Expand Down

0 comments on commit e5251ea

Please sign in to comment.