CDK: fix mypy

Signed-off-by: Artem Inzhyyants <[email protected]>

Author: artem1205

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

@@ -257,15 +257,15 @@ def _group_streams(
                             stream_slicer=declarative_stream.retriever.stream_slicer,
                         )
                     else:
-                        cursor: ConcurrentCursor
+                        # cursor: ConcurrentCursor
                         if (
-                            incremental_sync_component_definition.get("type")
+                            incremental_sync_component_definition
+                            and incremental_sync_component_definition.get("type")
                             == IncrementingCountCursorModel.__name__
                         ):
                             cursor = self._constructor.create_concurrent_cursor_from_incrementing_count_cursor(
                                 model_type=IncrementingCountCursorModel,
-                                component_definition=incremental_sync_component_definition,
-                                # type: ignore  # Not None because of the if condition above
+                                component_definition=incremental_sync_component_definition,  # type: ignore  # Not None because of the if condition above
                                 stream_name=declarative_stream.name,
                                 stream_namespace=declarative_stream.namespace,
                                 config=config or {},

airbyte_cdk/sources/streams/concurrent/state_converters/incrementing_count_stream_state_converter.py

@@ -81,7 +81,7 @@ def _get_sync_start(
         start: Optional[int],
     ) -> int:
         sync_start = start if start is not None else self.zero_value
-        prev_sync_low_water_mark = (
+        prev_sync_low_water_mark: Optional[int] = (
             stream_state[cursor_field.cursor_field_key]
             if cursor_field.cursor_field_key in stream_state
             else None