fix(cdk): update iterate_with_last_flag return type to allow None for empty generators

devin-ai-integration[bot] · darynaishchenko · devin-ai-integration[bot] · commit 695b819a2877 · 2026-02-05T12:38:21.000Z
Co-Authored-By: Daryna Ishchenko &lt;darina.ishchenko17@gmail.com&gt;
diff --git a/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py b/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py
@@ -39,7 +39,7 @@
 T = TypeVar("T")
 
 
-def iterate_with_last_flag(generator: Iterable[T]) -> Iterable[tuple[T, bool]]:
+def iterate_with_last_flag(generator: Iterable[T]) -> Iterable[tuple[T | None, bool]]:
     iterator = iter(generator)
 
     try:
