mypy

airbytehq · Dec 3, 2024 · 7d0b457 · 7d0b457
1 parent f2cb524
commit 7d0b457
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -314,11 +314,13 @@ def _group_streams(
 
         return concurrent_streams, synchronous_streams
 
-    def _is_datetime_incremental_without_partition_routing(
-        self, declarative_stream, incremental_sync_component_definition
-    ):
+    def _is_datetime_incremental_with_partition_routing(
+        self,
+        incremental_sync_component_definition: Mapping[str, Any],
+        declarative_stream: DeclarativeStream,
+    ) -> bool:
         return (
-            incremental_sync_component_definition
+            bool(incremental_sync_component_definition)
             and incremental_sync_component_definition.get("type", "")
             == DatetimeBasedCursorModel.__name__
             and self._stream_supports_concurrent_partition_processing(