code cleanup

This commit is contained in:
chris meyers 2018-10-11 13:40:54 -04:00 committed by mabashian
parent f5c10f99b0
commit a9365a3967
2 changed files with 3 additions and 6 deletions

View File

@ -133,10 +133,9 @@ class WorkflowDAG(SimpleDAG):
nodes.extend(children_all)
elif job and job.status == 'failed':
children_failed = self.get_dependencies(obj, 'success_nodes')
children_all = children_failed
nodes.extend(children_all)
nodes.extend(children_failed)
elif job and job.status == 'successful':
children_success = self.get_dependencies(obj, 'failure_nodes')
children_all = children_success
nodes.extend(children_all)
nodes.extend(children_success)
return [n['node_object'] for n in nodes_marked_do_not_run]

View File

@ -102,8 +102,6 @@ class TestWorkflowDAGFunctional(TransactionTestCase):
@pytest.mark.django_db
class TestWorkflowDNR():
'success', 'new'
@pytest.fixture
def workflow_job_fn(self):
def fn(states=['new', 'new', 'new', 'new', 'new', 'new']):