diff --git a/aredis_om/model/migrations/migrator.py b/aredis_om/model/migrations/migrator.py index 27cac65e..eb3d1b0b 100644 --- a/aredis_om/model/migrations/migrator.py +++ b/aredis_om/model/migrations/migrator.py @@ -130,6 +130,9 @@ async def detect_migrations(self): continue stored_hash = await conn.get(hash_key) + if isinstance(stored_hash, bytes): + stored_hash = stored_hash.decode('utf-8') + schema_out_of_date = current_hash != stored_hash if schema_out_of_date: