diff options
Diffstat (limited to 'glustolibs-io/shared_files/scripts/generate_io.py')
-rwxr-xr-x[-rw-r--r--] | glustolibs-io/shared_files/scripts/generate_io.py | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/glustolibs-io/shared_files/scripts/generate_io.py b/glustolibs-io/shared_files/scripts/generate_io.py index c9836ba80..d07bda7b0 100644..100755 --- a/glustolibs-io/shared_files/scripts/generate_io.py +++ b/glustolibs-io/shared_files/scripts/generate_io.py @@ -275,21 +275,21 @@ def start_populate_data(mount_point, io_dict, proc_queue = [] for each_io in io_dict.keys(): - q = multiprocessing.Queue() - proc_queue.append(q) - workload_type = io_dict[each_io]['workload_type'] - proc = multiprocessing.Process(target=(io_dict[each_io] - ['function_addr']), - args=(q, - (io_dict[each_io] - ['script_path']), - dirname, - (io_dict[each_io]['job_files'] - [workload_type]), - io_dict[each_io]['log_file'])) - proc_list.append(proc) - time.sleep(5) - proc.start() + q = multiprocessing.Queue() + proc_queue.append(q) + workload_type = io_dict[each_io]['workload_type'] + proc = multiprocessing.Process(target=(io_dict[each_io] + ['function_addr']), + args=(q, + (io_dict[each_io] + ['script_path']), + dirname, + (io_dict[each_io]['job_files'] + [workload_type]), + io_dict[each_io]['log_file'])) + proc_list.append(proc) + time.sleep(5) + proc.start() p = multiprocessing.Process( target=run_check_if_percent_to_fill_or_timeout_is_met, |