Skip to content

Commit

Permalink
fix: Avoid registering mappers for unselected streams
Browse files Browse the repository at this point in the history
  • Loading branch information
edgarrmondragon committed Feb 9, 2024
1 parent 068beae commit 78553d9
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions singer_sdk/mapper.py
Original file line number Diff line number Diff line change
Expand Up @@ -682,6 +682,10 @@ def register_raw_streams_from_catalog(self, catalog: Catalog) -> None:
catalog: TODO
"""
for catalog_entry in catalog.streams:
mask = catalog_entry.metadata.resolve_selection()
if not mask[()]:
# Skip unselected streams
continue
self.register_raw_stream_schema(
catalog_entry.stream or catalog_entry.tap_stream_id,
get_selected_schema(
Expand Down

0 comments on commit 78553d9

Please sign in to comment.