wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-07-01 21:29:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'threaded_monitor' of github.com:quantopian/zipline into threaded_monitor

Browse Source
This commit is contained in:
fawce
2012-07-03 11:38:21 -04:00
parent 31e0e8208c 6ad6b4dbc7
commit 80157153e3
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zipline/core/component.py
+2 -6
View File
@@ -346,7 +346,7 @@ class Component(object):
payload
)
self.control_out.send(heartbeat_frame)
log.info('Prestart Heartbeat' + self.get_id)
log.info('Prestart Heartbeat ' + self.get_id)
elif event == CONTROL_PROTOCOL.GO:
# Side effectful call from the controller to unlock
@@ -401,7 +401,7 @@ class Component(object):
self._exception = exc
exc_type, exc_value, exc_traceback = sys.exc_info()
trace = '\n>>>'.join(traceback.format_exception(exc_type, exc_value, exc_traceback))
trace = ''.join(traceback.format_exception(exc_type, exc_value, exc_traceback))
sys.stdout.write(trace)
if hasattr(self, 'control_out'):
@@ -423,10 +423,6 @@ class Component(object):
if self.out_socket:
self.out_socket.send(str(CONTROL_PROTOCOL.DONE))
#notify host we're done
# TODO: proper framing
self.sync_socket.send(self.get_id + ":" + str(CONTROL_PROTOCOL.DONE))
#notify controller we're done
done_frame = CONTROL_FRAME(
CONTROL_PROTOCOL.DONE,