diff --git a/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py b/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
index e43134f0..d1c594aa 100644
--- a/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
+++ b/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -165,7 +165,7 @@ def ensure_at_least_one_state_emitted(self) -> None:
         ):
             self._global_cursor = self._new_global_cursor
             self._lookback_window = self._timer.finish()
-        self._parent_state = self._partition_router.get_stream_state()
+            self._parent_state = self._partition_router.get_stream_state()
         self._emit_state_message()
 
     def _emit_state_message(self) -> None: