Skip to content
Snippets Groups Projects
Commit 7daa9bb9 authored by Maël Madon's avatar Maël Madon
Browse files

relaunch campaign1 after correcting the user_file bug

parent 212d2130
No related branches found
No related tags found
No related merge requests found
......@@ -25,7 +25,8 @@ with concurrent.futures.ProcessPoolExecutor() as executor:
instances = []
for i in range(nb_expe):
print(f"Submit expe {i}")
instances.append(executor.submit(start_instance, i, start_dates[i], True, True))
# start_instance(expe_num, start_date, prepare_workload, clean_log)
instances.append(executor.submit(start_instance, i, start_dates[i], False, True))
for instance in concurrent.futures.as_completed(instances):
print(f"Expe {instance.result()} terminated")
......@@ -37,7 +37,9 @@ def run_expe(expe_num, user_category, window_size, clean_log):
else:
w_size = f"{window_size}"
EXPE_DIR = f"{ROOT_DIR}/out/expe{expe_num}/{user_category}_window{w_size}"
EXPE_FILE = f"{EXPE_DIR}.yaml"
create_dir_rec_if_needed(EXPE_DIR)
create_dir_rec_if_needed(f"{EXPE_DIR}/cmd")
EXPE_FILE = f"{EXPE_DIR}/cmd/robinfile.yaml"
wl_folder = f'{WL_DIR}/expe{expe_num}'
pf = f"{ROOT_DIR}/platform/average_metacentrum.xml"
wl = f"{WL_DIR}/empty_workload.json"
......@@ -93,8 +95,7 @@ def start_instance(expe_num, start_date, prepare_workload=True, clean_log=False)
prepare_input_data(expe_num, start_date)
# Create expe folder
if not os.path.exists(f"{ROOT_DIR}/out/expe{expe_num}"):
os.makedirs(f"{ROOT_DIR}/out/expe{expe_num}")
create_dir_rec_if_needed(f"{ROOT_DIR}/out/expe{expe_num}")
# Run with Rigid behavior (the demand response window has no influence here)
run_expe(expe_num=expe_num,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment