Fix mypy errors

Author: tolik0

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -3436,7 +3436,6 @@ definitions:
         title: Group Size
         description: The number of partitions to include in each group. This determines how many partition values are batched together in a single slice.
         type: integer
-        minimum: 1
         examples:
           - 10
           - 50

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -6,7 +6,7 @@
 from enum import Enum
 from typing import Any, Dict, List, Literal, Optional, Union
 
-from pydantic.v1 import BaseModel, Extra, Field, conint
+from pydantic.v1 import BaseModel, Extra, Field
 
 
 class AuthFlowType(Enum):
@@ -2373,7 +2373,7 @@ class SubstreamPartitionRouter(BaseModel):
 
 class GroupingPartitionRouter(BaseModel):
     type: Literal["GroupingPartitionRouter"]
-    group_size: conint(ge=1) = Field(
+    group_size: int = Field(
         ...,
         description="The number of partitions to include in each group. This determines how many partition values are batched together in a single slice.",
         examples=[10, 50],

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -3056,6 +3056,8 @@ def create_grouping_partition_router(
         underlying_router = self._create_component_from_model(
             model=model.underlying_partition_router, config=config
         )
+        if model.group_size < 1:
+            raise ValueError(f"Group size must be greater than 0, got {model.group_size}")
 
         if not isinstance(underlying_router, PartitionRouter):
             raise ValueError(

airbyte_cdk/sources/declarative/partition_routers/grouping_partition_router.py

@@ -40,7 +40,7 @@ def stream_slices(self) -> Iterable[StreamSlice]:
             Iterable[StreamSlice]: An iterable of StreamSlice objects, where each slice contains a batch of partition values.
         """
         batch = []
-        seen_keys = set() if self.deduplicate else None
+        seen_keys = set()
 
         # Iterate over partitions lazily from the underlying router
         for partition in self.underlying_partition_router.stream_slices():