# lock with other concurrent reads).
@with_lock_file(lock_file, False)
def read_cache():
- try: ns.cfg = with_closing(file(cache_path))(lambda f: json.read(f.read()))
+ try: ns.cfg = with_closing(file(cache_path)) (
+ lambda f: json.read(f.read()))
except: ns.do_refresh = True
if ns.do_refresh:
@with_lock_file(lock_file)
def refresh_cache():
import yaml
- try: default_loader = yaml.CSafeLoader
- except: default_loader = yaml.SafeLoader
- ns.cfg = with_closing(file(src_path))(lambda f: yaml.load(f, default_loader))
- try: with_closing(file(cache_path, 'w'))(lambda f: f.write(json.write(ns.cfg)))
+ ns.cfg = with_closing(file(src_path)) (
+ lambda f: yaml.load(f, yaml.CSafeLoader))
+ try: with_closing(file(cache_path, 'w')) (
+ lambda f: f.write(json.write(ns.cfg)))
except: pass # silent failure
return ns.cfg