Coverage for appr/models/kv/etcd/models_index.py : 36%

Hot-keys on this page
r m x p toggle line displays
j k next/prev highlighted chunk
0 (zero) top of page
1 (one) first highlighted chunk
path = appr.models.kv.APPR_KV_PREFIX + path try: data = etcd_client.read(path).value except etcd.EtcdKeyError as excp: raise ResourceNotFound(excp.message, {"path": path}) return data
path = appr.models.kv.APPR_KV_PREFIX + key etcd_client.write(path, data)
path = appr.models.kv.APPR_KV_PREFIX + key try: etcd_client.delete(path) except etcd.EtcdKeyError: pass
if timeout is not None: timeout_time = time.time() + timeout # 5 minutes from now while True: try: etcd_client.write(lock_key, 'lock', prevExist=False, ttl=ttl) return True except etcd.EtcdAlreadyExist: if timeout is None or time.time() > timeout_time: raise UnableToLockResource("%s already locked" % lock_key, {"lock_key": lock_key, "ttl": ttl}) else: time.sleep(0.2)
return "%s%s.lock" % (appr.models.kv.APPR_KV_PREFIX, key)
return self._delete_data(lock_key.replace(appr.models.kv.APPR_KV_PREFIX, "")) |