fix: add missing slices key guard in else branch of emit_intermediate_state

devin-ai-integration[bot] · tolik0 · devin-ai-integration[bot] · commit 967e09a33050 · 2026-03-12T22:38:33.000Z
Co-Authored-By: gl_anatolii.yatsuk@airbyte.io &lt;gl_anatolii.yatsuk@airbyte.io&gt;
diff --git a/airbyte_cdk/sources/streams/concurrent/cursor.py b/airbyte_cdk/sources/streams/concurrent/cursor.py
@@ -311,6 +311,8 @@ def emit_intermediate_state(self, stream_slice: StreamSlice) -> None:
                     }
                 )
             else:
+                if "slices" not in self._concurrent_state:
+                    return
                 self._concurrent_state["slices"].append(
                     {
                         self._connector_state_converter.START_KEY: self.start,

Original file line number	Diff line number	Diff line change
`@@ -311,6 +311,8 @@ def emit_intermediate_state(self, stream_slice: StreamSlice) -> None:`
`311`	`311`	`}`
`312`	`312`	`)`
`313`	`313`	`else:`
	`314`	`+ if "slices" not in self._concurrent_state:`
	`315`	`+ return`
`314`	`316`	`self._concurrent_state["slices"].append(`
`315`	`317`	`{`
`316`	`318`	`self._connector_state_converter.START_KEY: self.start,`