分布式锁在未完成逻辑前过期怎么办？

import redis
import time
import uuid

def acquire_lock(client, lock_name, acquire_timeout=10, lock_timeout=10):
    identifier = str(uuid.uuid4())
    end = time.time() + acquire_timeout
    while time.time() < end:
        if client.set(lock_name, identifier, ex=lock_timeout, nx=True):
            return identifier
        time.sleep(0.01)
    return False

def extend_lock(client, lock_name, identifier, lock_timeout=10):
    if client.get(lock_name) == identifier:
        client.expire(lock_name, lock_timeout)
        return True
    return False

def release_lock(client, lock_name, identifier):
    pipe = client.pipeline(True)
    while True:
        try:
            pipe.watch(lock_name)
            if pipe.get(lock_name) == identifier:
                pipe.multi()
                pipe.delete(lock_name)
                pipe.execute()
                return True
            pipe.unwatch()
            break
        except redis.exceptions.WatchError:
            pass
    return False

# 使用示例
client = redis.StrictRedis(host='localhost', port=6379)

lock_name = 'my_lock'
identifier = acquire_lock(client, lock_name, acquire_timeout=10, lock_timeout=10)

if identifier:
    try:
        # 执行需要加锁的操作
        while True:
            # 模拟长时间操作
            time.sleep(1)
            # 定期更新锁的超时时间
            if not extend_lock(client, lock_name, identifier, lock_timeout=10):
                raise Exception("Lock extension failed")
    finally:
        release_lock(client, lock_name, identifier)

def execute_with_lock(client, lock_name, acquire_timeout=10, lock_timeout=10):
    identifier = acquire_lock(client, lock_name, acquire_timeout, lock_timeout)
    if identifier:
        try:
            # 执行需要加锁的操作
            while True:
                # 模拟长时间操作
                time.sleep(1)
                # 定期更新锁的超时时间
                if not extend_lock(client, lock_name, identifier, lock_timeout=10):
                    raise Exception("Lock extension failed")
        except Exception as e:
            # 处理异常情况
            print(f"Exception occurred: {e}")
            # 进行补偿操作
            compensate_for_failure()
        finally:
            release_lock(client, lock_name, identifier)
    else:
        print("Failed to acquire lock")

def compensate_for_failure():
    # 进行补偿操作，例如回滚事务、记录日志等
    pass

# 使用示例
client = redis.StrictRedis(host='localhost', port=6379)
execute_with_lock(client, 'my_lock')