Reorganize migrations module into domain-driven structure

Separates data and schema migrations into distinct modules for better
organization and maintainability. Moves built-in migrations to appropriate
builtin directories. Maintains full backward compatibility for all imports
and CLI commands. Fixes test field naming to eliminate Pydantic warnings.

Author: abrookins

aredis_om/__init__.py

@@ -1,7 +1,7 @@
 from .async_redis import redis  # isort:skip
 from .checks import has_redis_json, has_redisearch
 from .connections import get_redis_connection
-from .model.migrations.migrator import MigrationError, Migrator
+from .model.migrations.schema.legacy_migrator import MigrationError, Migrator
 from .model.model import (
     EmbeddedJsonModel,
     Field,

aredis_om/model/__init__.py

@@ -1,4 +1,4 @@
-from .migrations.migrator import MigrationError, Migrator
+from .migrations.schema.legacy_migrator import MigrationError, Migrator
 from .model import (
     EmbeddedJsonModel,
     Field,

aredis_om/model/cli/legacy_migrate.py

@@ -6,7 +6,7 @@
 import click
 
 from ...settings import get_root_migrations_dir
-from ..migrations.migrator import Migrator
+from ..migrations.schema.legacy_migrator import Migrator
 
 
 def run_async(coro):

aredis_om/model/cli/migrate.py

@@ -7,7 +7,7 @@
 from redis.exceptions import TimeoutError as RedisTimeoutError
 
 from ...settings import get_root_migrations_dir
-from ..migrations.schema_migrator import SchemaMigrator
+from ..migrations.schema import SchemaMigrator
 
 
 def run_async(coro):

aredis_om/model/cli/migrate_data.py

@@ -12,8 +12,8 @@
 from redis.exceptions import ConnectionError as RedisConnectionError
 from redis.exceptions import TimeoutError as RedisTimeoutError
 
-from ..migrations.data_migrator import DataMigrationError, DataMigrator
-from ..migrations.datetime_migration import ConversionFailureMode
+from ..migrations.data import DataMigrationError, DataMigrator
+from ..migrations.data.builtin.datetime_migration import ConversionFailureMode
 
 
 def run_async(coro):
@@ -489,7 +489,7 @@ def progress(migrations_dir: str, module: str, verbose: bool):
     import os
 
     from ...settings import get_root_migrations_dir
-    from ..migrations.datetime_migration import MigrationState
+    from ..migrations.data.builtin.datetime_migration import MigrationState
 
     resolved_dir = migrations_dir or os.path.join(
         get_root_migrations_dir(), "data-migrations"
@@ -546,7 +546,7 @@ def clear_progress(migrations_dir: str, module: str, yes: bool):
     import os
 
     from ...settings import get_root_migrations_dir
-    from ..migrations.datetime_migration import MigrationState
+    from ..migrations.data.builtin.datetime_migration import MigrationState
 
     resolved_dir = migrations_dir or os.path.join(
         get_root_migrations_dir(), "data-migrations"
@@ -588,7 +588,7 @@ def check_schema(migrations_dir: str, module: str):
     import os
 
     from ...settings import get_root_migrations_dir
-    from ..migrations.datetime_migration import DatetimeFieldDetector
+    from ..migrations.data.builtin.datetime_migration import DatetimeFieldDetector
 
     resolved_dir = migrations_dir or os.path.join(
         get_root_migrations_dir(), "data-migrations"

aredis_om/model/migrations/__init__.py

@@ -0,0 +1,36 @@
+"""
+Migration system for Redis OM.
+
+This module provides both data and schema migration capabilities for Redis OM
+Python applications. The migration system is organized into domain-specific
+submodules for better organization and maintainability.
+"""
+
+# Import from new locations for backward compatibility
+from .data import BaseMigration, DataMigrationError, DataMigrator
+from .schema import (
+    BaseSchemaMigration,
+    SchemaMigrationError,
+    SchemaMigrator,
+    Migrator,
+    MigrationError,
+    MigrationAction
+)
+
+# Maintain backward compatibility by exposing the same API
+__all__ = [
+    # Data migration classes
+    "BaseMigration",
+    "DataMigrationError",
+    "DataMigrator",
+
+    # Schema migration classes
+    "BaseSchemaMigration",
+    "SchemaMigrationError",
+    "SchemaMigrator",
+
+    # Legacy classes (for backward compatibility)
+    "Migrator",
+    "MigrationError",
+    "MigrationAction",
+]