Loading raps/utils.py +19 −5 Original line number Diff line number Diff line Loading @@ -54,6 +54,19 @@ def deep_subtract_dicts(a: dict, b: dict): return a def to_dict(arg): """ Normalizes arg to a dictionary if necessary. Used to convert between legacy argparse.Namespace objects and dictionaries. """ if isinstance(arg, dict): return arg elif isinstance(arg, argparse.Namespace): return vars(arg) else: raise ValueError(f"Cannot convert {arg} to dict") def sum_values(values): return sum(x[1] for x in values) if values else 0 Loading Loading @@ -456,14 +469,15 @@ def create_dir_indexed(dir: str, path: str = None) -> str: def next_arrival_byconfargs(config, args, reset=False): args = to_dict(args) arrival_rate = 1 arrival_time = config['JOB_ARRIVAL_TIME'] downscale = args.downscale downscale = args['downscale'] if args.job_arrival_rate: arrival_rate = args.job_arrival_rate if args.job_arrival_time: arrival_time = args.job_arrival_time if args['job_arrival_rate']: arrival_rate = args['job_arrival_rate'] if args['job_arrival_time']: arrival_time = args['job_arrival_time'] return next_arrival(arrival_rate / (arrival_time * downscale), reset) Loading Loading
raps/utils.py +19 −5 Original line number Diff line number Diff line Loading @@ -54,6 +54,19 @@ def deep_subtract_dicts(a: dict, b: dict): return a def to_dict(arg): """ Normalizes arg to a dictionary if necessary. Used to convert between legacy argparse.Namespace objects and dictionaries. """ if isinstance(arg, dict): return arg elif isinstance(arg, argparse.Namespace): return vars(arg) else: raise ValueError(f"Cannot convert {arg} to dict") def sum_values(values): return sum(x[1] for x in values) if values else 0 Loading Loading @@ -456,14 +469,15 @@ def create_dir_indexed(dir: str, path: str = None) -> str: def next_arrival_byconfargs(config, args, reset=False): args = to_dict(args) arrival_rate = 1 arrival_time = config['JOB_ARRIVAL_TIME'] downscale = args.downscale downscale = args['downscale'] if args.job_arrival_rate: arrival_rate = args.job_arrival_rate if args.job_arrival_time: arrival_time = args.job_arrival_time if args['job_arrival_rate']: arrival_rate = args['job_arrival_rate'] if args['job_arrival_time']: arrival_time = args['job_arrival_time'] return next_arrival(arrival_rate / (arrival_time * downscale), reset) Loading