refactor: Remove unused logger parameter from private catalog helper functions

singer_sdk/helpers/_catalog.py

@@ -10,8 +10,6 @@
 from singer_sdk.helpers._typing import is_object_type
 
 if t.TYPE_CHECKING:
-    from logging import Logger
-
     from singer_sdk._singerlib import Catalog, SelectionMask
 
 _MAX_LRU_CACHE = 500
@@ -22,11 +20,10 @@ def get_selected_schema(
     stream_name: str,
     schema: dict,
     mask: SelectionMask,
-    logger: Logger,
 ) -> dict:
     """Return a copy of the provided JSON schema, dropping any fields not selected."""
     new_schema = deepcopy(schema)
-    _pop_deselected_schema(new_schema, mask, stream_name, (), logger)
+    _pop_deselected_schema(new_schema, mask, stream_name, ())
     return new_schema
 
 
@@ -35,7 +32,6 @@ def _pop_deselected_schema(
     mask: SelectionMask,
     stream_name: str,
     breadcrumb: tuple[str, ...],
-    logger: Logger,
 ) -> None:
     """Remove anything from schema that is not selected.
 
@@ -75,15 +71,13 @@ def _pop_deselected_schema(
                 mask,
                 stream_name,
                 property_breadcrumb,
-                logger,
             )
 
 
 def pop_deselected_record_properties(
     record: dict[str, t.Any],
     schema: dict,
     mask: SelectionMask,
-    logger: Logger,
     breadcrumb: tuple[str, ...] = (),
 ) -> None:
     """Remove anything from record properties that is not selected.
@@ -104,7 +98,6 @@ def pop_deselected_record_properties(
                 val,
                 schema,
                 mask,
-                logger,
                 property_breadcrumb,
             )
 

singer_sdk/mapper.py

@@ -657,7 +657,6 @@ def register_raw_streams_from_catalog(self, catalog: Catalog) -> None:
                     catalog_entry.stream or catalog_entry.tap_stream_id,
                     catalog_entry.schema.to_dict(),
                     catalog_entry.metadata.resolve_selection(),
-                    self.logger,
                 ),
                 catalog_entry.key_properties,
             )

singer_sdk/streams/core.py

@@ -827,7 +827,7 @@ def _generate_record_messages(
         Yields:
             Record message objects.
         """
-        pop_deselected_record_properties(record, self.schema, self.mask, self.logger)
+        pop_deselected_record_properties(record, self.schema, self.mask)
         record = conform_record_data_types(
             stream_name=self.name,
             record=record,

singer_sdk/streams/sql.py

@@ -154,7 +154,6 @@ def get_selected_schema(self) -> dict:
             stream_name=self.name,
             schema=self.schema,
             mask=self.mask,
-            logger=self.logger,
         )
 
     # Get records from stream

tests/core/test_catalog_selection.py

@@ -197,12 +197,7 @@ def test_schema_selection(
     stream_name: str,
 ):
     """Test that schema selection rules are correctly applied to SCHEMA messages."""
-    selected_schema = get_selected_schema(
-        stream_name,
-        schema,
-        mask,
-        logging.getLogger(),
-    )
+    selected_schema = get_selected_schema(stream_name, schema, mask)
     assert (
         selected_schema["properties"]
         == PropertiesList(
@@ -247,7 +242,6 @@ def test_record_property_pop(
         record=record_pop,
         schema=schema,
         mask=mask,
-        logger=logging.getLogger(),
         breadcrumb=(),
     )
 

tests/samples/test_tap_countries.py

@@ -5,7 +5,6 @@
 import copy
 import io
 import json
-import logging
 import typing as t
 from contextlib import redirect_stdout
 
@@ -89,15 +88,13 @@ def test_with_catalog_entry():
         record=copied_record,
         schema=stream.schema,
         mask=stream.mask,
-        logger=logging.getLogger(),
     )
     assert copied_record == record
 
     new_schema = get_selected_schema(
         stream_name=stream.name,
         schema=stream.schema,
         mask=stream.metadata.resolve_selection(),
-        logger=logging.getLogger(),
     )
     assert new_schema == stream.schema