feat(taps): Abstract streams

meltano · Feb 26, 2025 · 5fc6499 · 5fc6499
1 parent 57a9bb4
commit 5fc6499
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/singer_sdk/streams/core.py b/singer_sdk/streams/core.py
@@ -110,6 +110,9 @@ class Stream(metaclass=abc.ABCMeta):  # noqa: PLR0904
     selected_by_default: bool = True
     """Whether this stream is selected by default in the catalog."""
 
+    __abstract__: bool = False
+    """Flag to indicate this stream is abstract and will not generate a catalog entry."""  # noqa: E501
+
     def __init__(
         self,
         tap: Tap,
@@ -321,6 +324,9 @@ def selected(self) -> bool:
         Returns:
             True if the stream is selected.
         """
+        if self.__abstract__:
+            return self.has_selected_descendents
+
         return self.mask.get((), True)
 
     @selected.setter

diff --git a/singer_sdk/tap_base.py b/singer_sdk/tap_base.py
@@ -338,6 +338,7 @@ def _singer_catalog(self) -> Catalog:
         return Catalog(
             (stream.tap_stream_id, stream._singer_catalog_entry)  # noqa: SLF001
             for stream in self.streams.values()
+            if not stream.__abstract__
         )
 
     def discover_streams(self) -> t.Sequence[Stream]: