Commit ff84032d authored by aknecht2's avatar aknecht2
Browse files

Fixed minor bug with duplicate dependencies being added to the workflow.

parent 1fa9a9d1
......@@ -254,7 +254,10 @@ class WorkflowModule(object):
master_jobs[param_dict["name"]] = job
for logical_name, param_dict in job_inputs.iteritems():
if param_dict["name"] in master_jobs:
dax.depends(child=job, parent=master_jobs[param_dict["name"]])
dep = Dependency(child=job, parent=master_jobs[param_dict["name"]])
# Prevent duplicate dependencies from being created
if not dax.hasDependency(dep):
dax.addDependency(dep)
else:
print msg
return
......
Markdown is supported
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