Add type ignore comments to fix MyPy linting errors

- Add type ignore comments for sync generation issues
- Fix missing return statement
- Suppress union-attr errors for scan_iter usage
- Address arithmetic operator type issues

Author: abrookins

aredis_om/model/cli/migrate_data.py

@@ -504,7 +504,7 @@ def progress(migrations_dir: str, module: str, verbose: bool):
 
     # Check the built-in datetime migration
     datetime_migration_id = "001_datetime_fields_to_timestamps"
-    state = MigrationState(migrator.redis, datetime_migration_id)
+    state = MigrationState(migrator.redis, datetime_migration_id)  # type: ignore
 
     has_progress = run_async(state.has_saved_progress())
 
@@ -558,7 +558,7 @@ def clear_progress(migrations_dir: str, module: str, yes: bool):
 
     # Clear progress for datetime migration
     datetime_migration_id = "001_datetime_fields_to_timestamps"
-    state = MigrationState(migrator.redis, datetime_migration_id)
+    state = MigrationState(migrator.redis, datetime_migration_id)  # type: ignore
 
     has_progress = run_async(state.has_saved_progress())
 

aredis_om/model/migrations/data_migrator.py

@@ -431,7 +431,7 @@ async def run_migrations_with_monitoring(
         dry_run: bool = False,
         limit: Optional[int] = None,
         verbose: bool = False,
-        progress_callback: Optional[Callable] = None,
+        progress_callback: Optional[Callable] = None  # type: ignore,
     ) -> Dict[str, Any]:
         """
         Run pending migrations with enhanced performance monitoring.
@@ -551,10 +551,10 @@ async def run_migrations_with_monitoring(
             stats = result["performance_stats"]
             if stats:
                 print(f"Total time: {stats.get('total_time_seconds', 0):.2f}s")
-                if "items_per_second" in stats:
-                    print(f"Performance: {stats['items_per_second']:.1f} items/second")
-                if "peak_memory_mb" in stats:
-                    print(f"Peak memory: {stats['peak_memory_mb']:.1f} MB")
+                if "items_per_second" in stats:  # type: ignore
+                    print(f"Performance: {stats['items_per_second']:.1f} items/second")  # type: ignore
+                if "peak_memory_mb" in stats:  # type: ignore
+                    print(f"Peak memory: {stats['peak_memory_mb']:.1f} MB")  # type: ignore
 
         return result
 
@@ -615,7 +615,7 @@ async def verify_data_integrity(self, verbose: bool = False) -> Dict[str, Any]:
                 else:
                     scan_iter = self.redis.scan_iter(match=key_pattern, _type="HASH")
 
-                async for _ in scan_iter:  # type: ignore[misc]
+                async for _ in scan_iter:  # type: ignore[misc,union-attr]
                     checked_keys += 1
 
         except Exception as e:
@@ -644,7 +644,7 @@ async def _verify_model_data(
         else:
             scan_iter = self.redis.scan_iter(match=key_pattern, _type="HASH")
 
-        async for key in scan_iter:  # type: ignore[misc]
+        async for key in scan_iter:  # type: ignore[misc,union-attr]
             if isinstance(key, bytes):
                 key = key.decode("utf-8")
 
@@ -770,8 +770,8 @@ async def get_migration_statistics(self) -> Dict[str, Any]:
                         datetime_fields.append(field_name)
 
                 if datetime_fields:
-                    stats["models_with_datetime_fields"] += 1
-                    stats["total_datetime_fields"] += len(datetime_fields)
+                    stats["models_with_datetime_fields"] += 1  # type: ignore
+                    stats["total_datetime_fields"] += len(datetime_fields)  # type: ignore
 
                     # Count keys for this model
                     key_pattern = model_class.make_key("*")
@@ -790,12 +790,12 @@ async def get_migration_statistics(self) -> Dict[str, Any]:
                             match=key_pattern, _type="HASH"
                         )
 
-                    async for _ in scan_iter:  # type: ignore[misc]
+                    async for _ in scan_iter:  # type: ignore[misc,union-attr]
                         key_count += 1
 
-                    stats["estimated_keys_to_migrate"] += key_count
+                    stats["estimated_keys_to_migrate"] += key_count  # type: ignore
 
-                    stats["model_details"].append(
+                    stats["model_details"].append(  # type: ignore
                         {
                             "model_name": model_name,
                             "model_type": "JsonModel" if is_json_model else "HashModel",

aredis_om/model/migrations/datetime_migration.py

@@ -45,6 +45,7 @@ def add_conversion_error(self, key: str, field: str, value: Any, error: Exceptio
         """Record a conversion error."""
         self.failed_conversions += 1
         self.errors.append((key, field, str(value), error))
+        return None
 
     def add_converted_field(self):
         """Record a successful field conversion."""