git://git.onelab.eu
/
plstackapi.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
2ef36c8
)
Load and save run times
syncsteps
origin/syncsteps
author
Sapan Bhatia
<gwsapan@gmail.com>
Mon, 2 Sep 2013 18:35:24 +0000
(14:35 -0400)
committer
Sapan Bhatia
<gwsapan@gmail.com>
Mon, 2 Sep 2013 18:35:24 +0000
(14:35 -0400)
planetstack/observer/event_loop.py
patch
|
blob
|
history
diff --git
a/planetstack/observer/event_loop.py
b/planetstack/observer/event_loop.py
index
b565a15
..
649918b
100644
(file)
--- a/
planetstack/observer/event_loop.py
+++ b/
planetstack/observer/event_loop.py
@@
-136,9
+136,8
@@
class PlanetStackObserver:
dependency_graph = step_graph
self.ordered_steps = toposort(dependency_graph, steps)
dependency_graph = step_graph
self.ordered_steps = toposort(dependency_graph, steps)
- self.last_run_times={}
- for e in self.ordered_steps:
- self.last_run_times[e.name]=0
+ self.load_run_times()
+
def check_duration(self):
try:
def check_duration(self):
try:
@@
-160,6
+159,21
@@
class PlanetStackObserver:
logger.info('Step %s does not have requested_interval set'%step.name)
raise StepNotReady
logger.info('Step %s does not have requested_interval set'%step.name)
raise StepNotReady
+ def load_run_times(self):
+ try:
+ jrun_times = open('/tmp/observer_run_times').read()
+ self.last_run_times = json.loads(jrun_times)
+ except:
+ self.last_run_times={}
+ for e in self.ordered_steps:
+ self.last_run_times[e.name]=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:
if (failed_step in self.dependency_graph[step.name]):
def check_class_dependency(self, step, failed_steps):
for failed_step in failed_steps:
if (failed_step in self.dependency_graph[step.name]):
@@
-215,6
+229,7
@@
class PlanetStackObserver:
self.update_run_time(sync_step)
except:
failed_steps.add(S)
self.update_run_time(sync_step)
except:
failed_steps.add(S)
+ self.save_run_times()
except:
logger.log_exc("Exception in observer run loop")
traceback.print_exc()
except:
logger.log_exc("Exception in observer run loop")
traceback.print_exc()