wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-06-28 23:24:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

Replayable error log.

Browse Source
This commit is contained in:
Stephen Diehl
2012-04-06 12:39:27 -04:00
parent 70d32f1bbc
commit 5aee03212d
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zipline/monitor.py
+10
View File
@@ -169,6 +169,8 @@ class Controller(object):
self.pub_socket = pub_socket
self.route_socket = route_socket
self.error_replay = {}
if logging:
self.logging = logging
else:
@@ -242,6 +244,13 @@ class Controller(object):
#self.logging.info("[Controller] Tracking : %s" % ([c for c in self.tracked],))
pass
def replay_errors(self):
"""
Replay the errors in the order they were reported to the
controller.
"""
return [ a for a in sorted(self.replay_errors.keys())]
# -------------
# Publications
# -------------
@@ -377,6 +386,7 @@ class Controller(object):
self.logging.info('[Controller] Component "%s" done.' % component)
def exception(self, component, failure):
self.error_replay[time.time()] = failure
self.logging.error('Component "%s" in exception state' % component)
# -----------------