Fix parent state update in case of error

airbytehq · Dec 18, 2024 · 5ee05f1 · 5ee05f1
1 parent a36726b
commit 5ee05f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: