Fix sync CLI commands and test failures

- Remove run_async() calls from sync CLI commands to prevent coroutine errors
- Add AsyncMock -> Mock transformation in unasync configuration
- Fix test_create_and_status_empty to use clean_redis fixture

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: abrookins

aredis_om/model/migrations/migrator.py

@@ -112,18 +112,19 @@ async def detect_migrations(self):
 
         for name, cls in model_registry.items():
             hash_key = schema_hash_key(cls.Meta.index_name)
-            
+
             # Try to get a connection, but handle event loop issues gracefully
             try:
                 conn = self.conn or cls.db()
             except RuntimeError as e:
                 if "Event loop is closed" in str(e):
                     # Model connection is bound to closed event loop, create fresh one
                     from ...connections import get_redis_connection
+
                     conn = get_redis_connection()
                 else:
                     raise
-            
+
             try:
                 schema = cls.redisearch_schema()
             except NotImplementedError:
@@ -137,6 +138,7 @@ async def detect_migrations(self):
                 if "Event loop is closed" in str(e):
                     # Connection had event loop issues, try with a fresh connection
                     from ...connections import get_redis_connection
+
                     conn = get_redis_connection()
                     try:
                         await conn.ft(cls.Meta.index_name).info()

aredis_om/model/migrations/schema_migrator.py

@@ -241,10 +241,10 @@ async def create_migration_file(self, name: str) -> Optional[str]:
         ops_lines.append("]")
         ops_literal = "\n".join(ops_lines)
 
-        template = f'''"""
+        template = '''"""
 Schema migration: {name}
 
-Created: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}
+Created: {created_time}
 """
 
 import hashlib
@@ -270,7 +270,7 @@ async def up(self) -> None:
                 await self.redis.ft(index_name).dropindex()
             except Exception:
                 pass
-            await self.redis.execute_command(f"FT.CREATE {index_name} {{new_schema}}".format(new_schema=new_schema))
+            await self.redis.execute_command(f"FT.CREATE {{index_name}} {{new_schema}}".format(index_name=index_name, new_schema=new_schema))
             new_hash = hashlib.sha1(new_schema.encode('utf-8')).hexdigest()
             await self.redis.set(schema_hash_key(index_name), new_hash)  # type: ignore[misc]
             await self.redis.set(schema_text_key(index_name), new_schema)  # type: ignore[misc]
@@ -284,11 +284,18 @@ async def down(self) -> None:
             except Exception:
                 pass
             if prev_schema:
-                await self.redis.execute_command(f"FT.CREATE {index_name} {{prev_schema}}".format(prev_schema=prev_schema))
+                await self.redis.execute_command(f"FT.CREATE {{index_name}} {{prev_schema}}".format(index_name=index_name, prev_schema=prev_schema))
                 prev_hash = hashlib.sha1(prev_schema.encode('utf-8')).hexdigest()
                 await self.redis.set(schema_hash_key(index_name), prev_hash)  # type: ignore[misc]
                 await self.redis.set(schema_text_key(index_name), prev_schema)  # type: ignore[misc]
-'''
+'''.format(
+            name=name,
+            created_time=datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
+            class_name=class_name,
+            migration_id=migration_id,
+            description=description,
+            ops_literal=ops_literal,
+        )
 
         with open(filepath, "w") as f:
             f.write(template)

aredis_om/model/model.py

@@ -2446,6 +2446,7 @@ async def save(
             if "Event loop is closed" in str(e):
                 # Connection is bound to closed event loop, refresh it and retry
                 from ..connections import get_redis_connection
+
                 self._meta.database = get_redis_connection()
                 db = self._get_db(pipeline)
                 await db.hset(self.key(), mapping=document)
@@ -2656,6 +2657,7 @@ async def save(
             if "Event loop is closed" in str(e):
                 # Connection is bound to closed event loop, refresh it and retry
                 from ..connections import get_redis_connection
+
                 self._meta.database = get_redis_connection()
                 db = self._get_db(pipeline)
                 await db.json().set(self.key(), Path.root_path(), data)

make_sync.py

@@ -9,6 +9,7 @@
     ":tests.": ":tests_sync.",
     "pytest_asyncio": "pytest",
     "py_test_mark_asyncio": "py_test_mark_sync",
+    "AsyncMock": "Mock",
 }
 
 

tests/conftest.py

@@ -23,9 +23,10 @@ async def redis():
     # Per-test client bound to current loop; close after each test
     # Force a new connection for each test to avoid event loop issues
     import os
+
     url = os.environ.get("REDIS_OM_URL", "redis://localhost:6380?decode_responses=True")
     from aredis_om import redis as redis_module
-    
+
     client = redis_module.Redis.from_url(url, decode_responses=True)
     try:
         # Ensure client is working with current event loop