feat: Stream sync context is now available to all instances methods a…

…s a `Stream.context` attribute

singer_sdk/streams/core.py

@@ -72,7 +72,12 @@
 
 
 class Stream(metaclass=abc.ABCMeta):  # noqa: PLR0904
-    """Abstract base class for tap streams."""
+    """Abstract base class for tap streams.
+
+    :ivar context: Stream partition or context dictionary.
+
+    .. versionadded:: 0.39.0
+    """
 
     STATE_MSG_FREQUENCY = 10000
     """Number of records between state messages."""
@@ -134,6 +139,8 @@ def __init__(
         self.logger: logging.Logger = tap.logger.getChild(self.name)
         self.metrics_logger = tap.metrics_logger
         self.tap_name: str = tap.name
+        self.context: Context | None = None
+
         self._config: dict = dict(tap.config)
         self._tap = tap
         self._tap_state = tap.state
@@ -1173,6 +1180,7 @@ def sync(self, context: Context | None = None) -> None:
         if context:
             msg += f" with context: {context}"
         self.logger.info("%s...", msg)
+        self.context = context
 
         # Use a replication signpost, if available
         signpost = self.get_replication_key_signpost(context)

singer_sdk/streams/rest.py

@@ -376,7 +376,7 @@ def request_records(self, context: Context | None) -> t.Iterable[dict]:
         Yields:
             An item for every record in the response.
         """
-        paginator = self.get_new_paginator(context=context)
+        paginator = self.get_new_paginator()
         decorated_request = self.request_decorator(self._request)
         pages = 0
 
@@ -519,12 +519,9 @@ def prepare_request_payload(
                 next page of data.
         """
 
-    def get_new_paginator(self, *, context: Context | None = None) -> BaseAPIPaginator:  # noqa: ARG002
+    def get_new_paginator(self) -> BaseAPIPaginator:
         """Get a fresh paginator for this API endpoint.
 
-        Args:
-            context: Stream partition or context dictionary.
-
         Returns:
             A paginator instance.
         """