v2 is comming
diff --git a/wally/suits/io/fio_task_parser.py b/wally/suits/io/fio_task_parser.py
index e8ec6f9..c08bd37 100644
--- a/wally/suits/io/fio_task_parser.py
+++ b/wally/suits/io/fio_task_parser.py
@@ -284,6 +284,10 @@
sec.vals['unified_rw_reporting'] = '1'
+ if isinstance(sec.vals['size'], Var):
+ raise ValueError("Variable {0} isn't provided".format(
+ sec.vals['size'].name))
+
sz = ssize2b(sec.vals['size'])
offset = sz * ((MAGIC_OFFSET * counter[0]) % 1.0)
offset = int(offset) // 1024 ** 2
@@ -294,6 +298,10 @@
if val.name in new_vars:
sec.vals[name] = new_vars[val.name]
+ for vl in sec.vals.values():
+ if isinstance(vl, Var):
+ raise ValueError("Variable {0} isn't provided".format(vl.name))
+
params = sec.vals.copy()
params['UNIQ'] = 'UN{0}'.format(counter[0])
params['COUNTER'] = str(counter[0])
@@ -404,20 +412,16 @@
'runcycle': argv_obj.runcycle,
}
- sliced_it = fio_cfg_compile(job_cfg, argv_obj.jobfile,
- params, **slice_params)
+ sec_it = fio_cfg_compile(job_cfg, argv_obj.jobfile,
+ params, **slice_params)
if argv_obj.action == 'estimate':
- sum_time = 0
- for cfg_slice in sliced_it:
- sum_time += sum(map(execution_time, cfg_slice))
- print sec_to_str(sum_time)
+ print sec_to_str(sum(map(execution_time, sec_it)))
elif argv_obj.action == 'num_tests':
- print sum(map(len, map(list, sliced_it)))
+ print sum(map(len, map(list, sec_it)))
elif argv_obj.action == 'compile':
splitter = "\n#" + "-" * 70 + "\n\n"
- for cfg_slice in sliced_it:
- print splitter.join(map(str, cfg_slice))
+ print splitter.join(map(str, sec_it))
return 0