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

Performance reports take either socket address or socket.

Browse Source
This commit is contained in:
Stephen Diehl
2012-04-06 13:31:39 -04:00
parent 5aee03212d
commit 80bfbd5dcb
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zipline/finance/performance.py
+7 -4
View File
@@ -185,11 +185,14 @@ class PerformanceTracker():
Publish the performance results asynchronously to a
socket.
"""
ctx = context or zmq.Context.instance()
sock = ctx.socket(zmq.PUSH)
sock.connect(zmq_socket)
if isinstance(zmq_socket, zmq.Socket):
self.result_stream = zmq_socket
else:
ctx = context or zmq.Context.instance()
sock = ctx.socket(zmq.PUSH)
sock.connect(zmq_socket)
self.result_stream = sock
self.result_stream = sock
def to_dict(self):
"""