Merge branch 'dev' of https://github.com/vnpy/vnpy into dev
This commit is contained in:
commit
98716eec55
@ -91,7 +91,7 @@ class CtaEngine(BaseEngine):
|
|||||||
self.stop_order_count = 0 # for generating stop_orderid
|
self.stop_order_count = 0 # for generating stop_orderid
|
||||||
self.stop_orders = {} # stop_orderid: stop_order
|
self.stop_orders = {} # stop_orderid: stop_order
|
||||||
|
|
||||||
self.init_executor = ThreadPoolExecutor(max_workers=3)
|
self.init_executor = ThreadPoolExecutor(max_workers=1)
|
||||||
|
|
||||||
self.rq_client = None
|
self.rq_client = None
|
||||||
self.rq_symbols = set()
|
self.rq_symbols = set()
|
||||||
|
@ -49,8 +49,12 @@ class RqdataClient:
|
|||||||
if not self.username or not self.password:
|
if not self.username or not self.password:
|
||||||
return False
|
return False
|
||||||
|
|
||||||
rqdata_init(self.username, self.password,
|
rqdata_init(
|
||||||
('rqdatad-pro.ricequant.com', 16011))
|
self.username,
|
||||||
|
self.password,
|
||||||
|
('rqdatad-pro.ricequant.com', 16011),
|
||||||
|
use_pool=True
|
||||||
|
)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
df = rqdata_all_instruments(date=datetime.now())
|
df = rqdata_all_instruments(date=datetime.now())
|
||||||
|
Loading…
Reference in New Issue
Block a user