Changed the lockcli to wait for the shared lock to be released.
Signed-off-by: Baha Mesleh <baha.mesleh@nokia.com>
Change-Id: Ibb3c603cf58cc03e0558a2452288bb610ed18d7d
def __call__(self, args):
self._init_api(args.server, args.port, args.verbose)
lock = etcd.Lock(self.client, args.id)
def __call__(self, args):
self._init_api(args.server, args.port, args.verbose)
lock = etcd.Lock(self.client, args.id)
- result = lock.acquire(blocking=False, lock_ttl=args.timeout)
+ result = lock.acquire(blocking=True, lock_ttl=args.timeout)
if not result:
raise Exception('Lock taken!')
if not result:
raise Exception('Lock taken!')