Commit f2c2ffc9 authored by aknecht2's avatar aknecht2
Browse files

Added helper method t oget all dependent jobs necessary for a workflow to run.

parent d2db87f0
......@@ -348,6 +348,18 @@ class WorkflowModule(object):
dax.depends(child = job, parent = master_jobs[file_dict["name"]])
return
def get_dependent_jobs(dax, master_jobs, master_files, markers, inputs, additional_inputs):
dep_list = []
job_list = self._get_job_list(markers)
for job_dict in job_list:
job_name = job_dict.keys()[0]
job_info = job_dict[job_name]
job_inputs = self._setup_job_params(master_files, job_info, markers, "inputs", inputs, outputs)
for file_dict in job_inputs:
if file_dict["name"] in master_jobs:
dep_list.append(file_dict["name"])
return dep_list
def _setup_job_params(self, master_files, job_info, markers, param_type, arg_params, outputs):
"""
:param master_files: Master file dictionary mapping file_names -> file objects.
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment