From 5ee05f11d67e0cccdb819386449b22335a7dc8d0 Mon Sep 17 00:00:00 2001 From: Anatolii Yatsuk Date: Wed, 18 Dec 2024 19:18:00 +0200 Subject: [PATCH] Fix parent state update in case of error --- .../declarative/incremental/concurrent_partition_cursor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: