handle case of node with null UJT

This commit is contained in:
AlanCoding 2017-01-10 18:50:52 -05:00
parent fc087fb47b
commit 8f259f2bb7
2 changed files with 4 additions and 0 deletions

View File

@ -114,6 +114,8 @@ class TaskManager():
dag = WorkflowDAG(workflow_job)
spawn_nodes = dag.bfs_nodes_to_run()
for spawn_node in spawn_nodes:
if spawn_node.unified_job_template is None:
continue
kv = spawn_node.get_job_kwargs()
job = spawn_node.unified_job_template.create_unified_job(**kv)
spawn_node.job = job

View File

@ -67,6 +67,8 @@ class WorkflowDAG(SimpleDAG):
obj = n['node_object']
job = obj.job
if obj.unified_job_template is None:
continue
if not job:
return False
# Job is about to run or is running. Hold our horses and wait for