test_session_integration.py 文件源码

def test_if_two_instance_are_deleted_from_redis(self, session, redis):
        inst1 = await Model10.new(session, id=1)
        inst2 = await Model10.new(session, id=2)
        session.add_all([inst1, inst2])
        await session.commit()

        assert await redis.hgetall(Model10.__key__) == {
            b'1': ujson.dumps({b'id': 1}).encode(),
            b'2': ujson.dumps({b'id': 2}).encode()
        }

        session.delete(inst1)
        session.delete(inst2)
        await session.commit()

        assert await redis.hgetall(Model10.__key__) == {}