From 2fd8d300b629af8ab0427dddbd396b3af093b4df Mon Sep 17 00:00:00 2001 From: Tony Mack Date: Sat, 5 Oct 2013 09:59:38 -0400 Subject: [PATCH] fix check_class_dependency() --- planetstack/observer/event_loop.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/planetstack/observer/event_loop.py b/planetstack/observer/event_loop.py index 9f3bc5a..482c5a8 100644 --- a/planetstack/observer/event_loop.py +++ b/planetstack/observer/event_loop.py @@ -194,16 +194,17 @@ class PlanetStackObserver: self.last_run_times[e]=0 - def save_run_times(self): run_times = json.dumps(self.last_run_times) open('/tmp/observer_run_times','w').write(run_times) def check_class_dependency(self, step, failed_steps): - for failed_step in failed_steps: - step.dependencies = self.model_dependency_graph.get(step.provides[0].__name__, []) - if (failed_step in step.dependencies): - raise StepNotReady + step.dependenices = [] + for obj in step.provides: + step.dependenices.extend(self.model_dependency_graph.get(obj.__name__, [])) + for failed_step in failed_steps: + if (failed_step in step.dependencies): + raise StepNotReady def run(self): if not self.driver.enabled or not self.driver.has_openstack: -- 2.43.0