From 3c95467ec765c95620e981ddea23781c8aaabafa Mon Sep 17 00:00:00 2001 From: Mark Turiansky Date: Sun, 5 Sep 2021 14:23:25 -0700 Subject: [PATCH 1/2] add timout for getting from queue in _t_order_create --- alpaca_backtrader_api/alpacastore.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/alpaca_backtrader_api/alpacastore.py b/alpaca_backtrader_api/alpacastore.py index 8c175557..1d322f6a 100644 --- a/alpaca_backtrader_api/alpacastore.py +++ b/alpaca_backtrader_api/alpacastore.py @@ -203,6 +203,7 @@ class AlpacaStore(with_metaclass(MetaSingleton, object)): ('secret_key', ''), ('paper', False), ('account_tmout', 10.0), # account balance refresh timeout + ('order_tmout', 0.05), # order status check timeout ('api_version', None) ) @@ -753,9 +754,10 @@ def _check_if_transaction_occurred(order_id): while True: try: - if self.q_ordercreate.empty(): + try: + msg = self.q_ordercreate.get(timeout=self.p.order_tmout) + except queue.Empty: continue - msg = self.q_ordercreate.get() if msg is None: continue oref, okwargs = msg From 062452cc90c58c402cfdaccaa84bba58f903dbee Mon Sep 17 00:00:00 2001 From: Mark Turiansky Date: Sun, 5 Sep 2021 14:35:00 -0700 Subject: [PATCH 2/2] added docstring on order_tmout --- alpaca_backtrader_api/alpacastore.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/alpaca_backtrader_api/alpacastore.py b/alpaca_backtrader_api/alpacastore.py index 1d322f6a..d043a8c2 100644 --- a/alpaca_backtrader_api/alpacastore.py +++ b/alpaca_backtrader_api/alpacastore.py @@ -193,6 +193,9 @@ class AlpacaStore(with_metaclass(MetaSingleton, object)): - ``account_tmout`` (default: ``10.0``): refresh period for account value/cash refresh + + - ``order_tmout`` (default: ``0.05``): how often the order creation queue + is checked within _t_create_order ''' BrokerCls = None # broker class will autoregister