Refreshing a lock defined in chapter 6 of Redis in Action

refresh_lock.py

'''
Answer to this thread:
http://www.manning-sandbox.com/thread.jspa?messageID=140363

'''

def refresh_lock(conn, lockname, identifier, timeout=10):
    pipe = conn.pipeline(True)
    lockname = 'lock:' + lockname

    while True:
        try:
            pipe.watch(lockname)
            if pipe.get(lockname) == identifier:
                pipe.multi()
                pipe.expire(lockname, timeout)
                pipe.execute()
                return True

            pipe.unwatch()
            break

        except redis.exceptions.WatchError:
            pass

    return False

Very useful, thanks! Did you forget the line pipe.set(lockname, identifier)?