ENH: Make SGEGraph only submit jobs that need running.

BRAINSia · Sep 20, 2020 · d48878d · d48878d
1 parent 36d83d0
commit d48878d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/AutoWorkup/BAW/workflows/utils.py b/AutoWorkup/BAW/workflows/utils.py
@@ -29,6 +29,9 @@ def run_workflow(workflow, plugin="Linear", plugin_args=OrderedDict()):
     for key, value in list(workflow.config["execution"].items()):
         print("EXECUTE ENV: {0}={1}".format(key, value))
     try:
+        if plugin == "SGEGraph":
+             plugin_args['dont_resubmit_completed_jobs']= True
+             print(f"{plugin_args}")
         workflow.run(plugin=plugin, plugin_args=plugin_args)
     except:
         print(("=+-+" * 25))