diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-07-10 04:48:36 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-07-10 04:48:36 +0000 |
| commit | 2c23861558ea72e8f5e70d356a255a6af281067a (patch) | |
| tree | 5d2b76df857f6dbc992e0885a827c8bbef13186a /taskflow/patterns/linear_flow.py | |
| parent | 9ffcbd676e67cdb8254395aa868aa1c26255b78b (diff) | |
| parent | 90182f6ae6b370acf276f14f08a85c30c3938164 (diff) | |
| download | taskflow-2c23861558ea72e8f5e70d356a255a6af281067a.tar.gz | |
Merge "Use the runner interface as the best task lookup."
Diffstat (limited to 'taskflow/patterns/linear_flow.py')
| -rw-r--r-- | taskflow/patterns/linear_flow.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/taskflow/patterns/linear_flow.py b/taskflow/patterns/linear_flow.py index b5aa3fd..6f622bb 100644 --- a/taskflow/patterns/linear_flow.py +++ b/taskflow/patterns/linear_flow.py @@ -81,12 +81,12 @@ class Flow(base.Flow): def _associate_providers(self, runner): # Ensure that some previous task provides this input. who_provides = {} - task_requires = set(utils.get_attr(runner.task, 'requires', [])) + task_requires = runner.requires LOG.debug("Finding providers of %s for %s", task_requires, runner) for r in task_requires: provider = None for before_me in runner.runs_before: - if r in set(utils.get_attr(before_me.task, 'provides', [])): + if r in before_me.provides: provider = before_me break if provider: |