diff --git a/singer_sdk/streams/sql.py b/singer_sdk/streams/sql.py index 2b610a2a5f..6089d5e11c 100644 --- a/singer_sdk/streams/sql.py +++ b/singer_sdk/streams/sql.py @@ -11,7 +11,7 @@ import singer_sdk.helpers._catalog as catalog from singer_sdk._singerlib import CatalogEntry, MetadataMapping from singer_sdk.connectors import SQLConnector -from singer_sdk.streams.core import Stream +from singer_sdk.streams.core import REPLICATION_INCREMENTAL, Stream if t.TYPE_CHECKING: from singer_sdk.streams.core import Context @@ -227,7 +227,7 @@ def is_sorted(self) -> bool: Returns: `True` if stream is sorted. Defaults to `False`. """ - return self.replication_key is not None + return self.replication_method == REPLICATION_INCREMENTAL __all__ = ["SQLConnector", "SQLStream"]