python:aioredis事务，watch使用

async def test_get1(request):
    temp_key = 'test:hello'
    async with request.app.redis_pool.get() as redis:
        await redis.watch(temp_key)
        trs = redis.multi_exec()
        for i in range(1000):
            trs.get(temp_key)
            trs.set(temp_key, 'hello')
        ret = await trs.execute()
        logging.info("ret {}".format(ret))

    return html('hello')


async def test_get2(request):
    temp_key = 'test:hello'
    async with request.app.redis_pool.get() as redis:
        while 1:
            redis.set(temp_key, 'he')
            await asyncio.sleep(0.1)

    return html('hello')

aioredis.errors.WatchVariableError: ('WatchVariableError errors:', 'WATCH variable has changed')