Skip to content
Snippets Groups Projects
Commit 2a0dbd9c authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Small code refactoring

parent 7f964e67
No related branches found
No related tags found
1 merge request!74Feat: Add summary job option
......@@ -642,6 +642,7 @@ def run():
break
for cnum, cval in enumerate(cvals):
# Job is not final if there are dependent notebooks
jobid = concurrent_run(run_tmp_path, nb, notebook, args,
cvar, [cval, ] if not isinstance(
cval, list) and cvtype is list else cval,
......@@ -658,9 +659,10 @@ def run():
"{}/{}".format(os.path.dirname(__file__), notebook))
with open(notebook_path, "r") as f:
nb = nbformat.read(f, as_version=4)
final_job = i == len(dep_notebooks) - 1
jobid = concurrent_run(run_tmp_path, nb, os.path.basename(notebook),
args,
final_job=i==len(dep_notebooks)-1,
final_job=final_job,
job_list=joblist, fmtcmd=fmtcmd,
cluster_cores=cluster_cores,
sequential=sequential, priority=priority,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment