|
@@ -32,7 +32,7 @@ def run(seq):
|
|
|
while True:
|
|
while True:
|
|
|
time.sleep(3)
|
|
time.sleep(3)
|
|
|
now_date = dt.now()
|
|
now_date = dt.now()
|
|
|
- if not client.is_connected() or dt.now() > now_date.replace(hour=13, minute=26, second=0):
|
|
|
|
|
|
|
+ if not client.is_connected() or dt.now() > now_date.replace(hour=15, minute=00, second=0):
|
|
|
xtdata.unsubscribe_quote(seq)
|
|
xtdata.unsubscribe_quote(seq)
|
|
|
raise Exception('行情服务连接断开')
|
|
raise Exception('行情服务连接断开')
|
|
|
break
|
|
break
|
