diff --git a/singer_sdk/mapper.py b/singer_sdk/mapper.py index e15d39f7e..10f315084 100644 --- a/singer_sdk/mapper.py +++ b/singer_sdk/mapper.py @@ -729,6 +729,11 @@ 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(