Update ib_gateway.py

jinbinhan · Apr 30, 2021 · 34d7117 · 34d7117
1 parent f3f2563
commit 34d7117
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/vnpy/gateway/ib/ib_gateway.py b/vnpy/gateway/ib/ib_gateway.py
@@ -253,6 +253,7 @@ def __init__(self, gateway: BaseGateway):
         self.reqid = 0
         self.orderid = 0
         self.clientid = 0
+        self.history_reqid = 0
         self.account = ""
         self.ticks = {}
         self.orders = {}
@@ -313,6 +314,10 @@ def error(self, reqId: TickerId, errorCode: int, errorString: str):  # pylint: d
         Callback of error caused by specific request.
         """
         super().error(reqId, errorCode, errorString)
+        if reqId == self.history_reqid:
+            self.history_condition.acquire()
+            self.history_condition.notify()
+            self.history_condition.release()
 
         msg = f"信息通知，代码：{errorCode}，内容: {errorString}"
         self.gateway.write_log(msg)
@@ -806,6 +811,7 @@ def query_history(self, req: HistoryRequest):
         else:
             bar_type = "TRADES"
 
+        self.history_reqid = self.reqid
         self.client.reqHistoricalData(
             self.reqid,
             ib_contract,