diff --git a/singer_sdk/streams/core.py b/singer_sdk/streams/core.py index 07df36dfe2..0f5c7b8d36 100644 --- a/singer_sdk/streams/core.py +++ b/singer_sdk/streams/core.py @@ -156,6 +156,14 @@ def __init__( self.child_streams: list[Stream] = [] self.sync_result: SyncResult | None = None + # Initialize state manager + self._state_manager = StreamStateManager( + tap_name=tap.name, + stream_name=self.name, + tap_state=self._tap_state, + state_partitioning_keys=self._state_partitioning_keys, + ) + if schema: if isinstance(schema, (PathLike, str)): if not Path(schema).is_file(): # ty: ignore[invalid-argument-type]