redis中为什么会报这个错误

import redis
import random
from db.redis_pool_db import pool
from concurrent.futures import ThreadPoolExecutor

list_a = set()

conn = redis.Redis(
    connection_pool=pool)

thread = ThreadPoolExecutor(300)

while True:
    if len(list_a) == 1000:
        break
    numbers = random.randint(10000, 100000)
    list_a.add(numbers)

conn.delete("kill_total", "kill_num", "kill_flag", "kill_user")
conn.set("kill_total", 0)
conn.set("kill_num", 10)
conn.set("kill_flag", 1)
conn.expire("kill_flag", 600)
del conn


def dev():
    connection = redis.Redis(
        connection_pool=pool
    )
    pipline = connection.pipeline()
    try:
        if connection.exists("kill_flag") == 1:
            pipline.watch("kill_total", "kill_user")
            total = int(pipline.get("kill_total").decode("utf-8"))
            num = int(pipline.get("kill_num").decode("utf-8"))
            if total < num:
                pipline.multi()
                total = int(pipline.get("kill_total").decode("utf-8"))
                numbers_b = list_a.pop()
                pipline.incr("kill_total")
                pipline.rpush("kill_user", numbers_b)
                pipline.execute()

    except Exception as e:
        print(e)
    finally:
        if "pipline" in dir():
            pipline.reset()

        if "connection" in dir():
            del connection


for i in range(100):
    thread.submit(dev)

print("秒杀已结束")

total = int(pipline.get("kill_total").decode("utf-8"))

这行放在了开启事务下面，然后就会报错运行不了。这个是怎么回事啊

同学，你好！由于使用了 pipline.watch() 监视了 "kill_total" 和 "kill_user" 这两个键，如果在 pipline.execute() 之前有对这两个键进行了修改，那么监视就会失败。虽然同学使用了 pipline.multi() 开始一个事务，但在执行事务之前又重新执行了 pipline.get("kill_total") 获取 total 值。从而引发了错误

祝学习愉快~

没懂，自增加一不是修改吗？