commit ea41f56b95951ae9c5e73906c3803b815fb64278
author Tony Mack <tmack@paris.CS.Princeton.EDU> Wed Sep 25 08:10:40 2013 -0400
committer Tony Mack <tmack@paris.CS.Princeton.EDU> Wed Sep 25 08:10:40 2013 -0400
tree 85274050212b47b14b6c193c4b9ab479e07b0468
parent 3bf77b0117ee01565276e9a9c50627510ab2a5df

fix bugs

planetstack/observer/event_loop.py

diff --git a/planetstack/observer/event_loop.py b/planetstack/observer/event_loop.py
index 28e78de..23e873f 100644
--- a/planetstack/observer/event_loop.py
+++ b/planetstack/observer/event_loop.py
@@ -165,12 +165,12 @@
         self.last_run_times[step.name]=time.time()
 
     def check_schedule(self, step):
-        time_since_last_run = time.time() - self.last_run_times[step.name]
+        time_since_last_run = time.time() - self.last_run_times[step.__name__]
         try:
             if (time_since_last_run < step.requested_interval):
                 raise StepNotReady
         except AttributeError:
-            logger.info('Step %s does not have requested_interval set'%step.name)
+            logger.info('Step %s does not have requested_interval set'%step.__name__)
             raise StepNotReady
     
     def load_run_times(self):
@@ -190,7 +190,8 @@
 
     def check_class_dependency(self, step, failed_steps):
         for failed_step in failed_steps:
-            if (failed_step in self.dependency_graph[step.name]):
+            dependencies = self.model_dependency_graph.get(step.provides[0].__name__, [])
+            if (failed_step in dependencies):
                 raise StepNotReady
 
     def run(self):
@@ -215,6 +216,7 @@
                     start_time=time.time()
                     
                     sync_step = step(driver=self.driver)
+                    sync_step.__name__ = step.__name__    
                     #sync_step.dependencies = self.dependencies[sync_step.name]
                     sync_step.debug_mode = debug_mode
 
@@ -243,7 +245,7 @@
                             failed_step_objects.extend(failed_objects)
                             self.update_run_time(sync_step)
                         except:
-                            failed_steps.add(S)
+                            failed_steps.append(S)
                 self.save_run_times()
             except:
                 logger.log_exc("Exception in observer run loop")