mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-17 11:25:55 +08:00
switched to gevent zmq, fixed hangups
This commit is contained in:
+1
-1
@@ -2,7 +2,7 @@
|
||||
Provides simulated data feed services...
|
||||
"""
|
||||
import multiprocessing
|
||||
import zmq
|
||||
from gevent_zeromq import zmq
|
||||
import json
|
||||
import copy
|
||||
import threading
|
||||
|
||||
@@ -3,7 +3,7 @@ Commonly used messaging components.
|
||||
"""
|
||||
import json
|
||||
import uuid
|
||||
import zmq
|
||||
from gevent_zeromq import zmq
|
||||
|
||||
import zipline.util as qutil
|
||||
|
||||
|
||||
+1
-1
@@ -2,7 +2,7 @@
|
||||
Provides data handlers that can push messages to a zipline.core.DataFeed
|
||||
"""
|
||||
import datetime
|
||||
import zmq
|
||||
from gevent_zeromq import zmq
|
||||
import json
|
||||
import random
|
||||
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import zmq
|
||||
from gevent_zeromq import zmq
|
||||
import json
|
||||
import zipline.util as qutil
|
||||
|
||||
|
||||
Reference in New Issue
Block a user