wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-08-05 12:50:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix cleanup on retries

Browse Source 
From redo docs:

> cleanup (callable): optional; called if one of retry_exceptions is caught. __No arguments are passed to the cleanup function__; if your cleanup requires arguments, consider using functools.partial or a lambda function.
This commit is contained in:
Caio Oliveira
2018-01-01 23:49:52 -02:00
parent 35fb862fa9
commit 74c10c45a0
3 changed files with 14 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
catalyst/exchange/exchange_algorithm.py
+7 -19
View File
@@ -655,10 +655,7 @@ class ExchangeTradingAlgorithmLive(ExchangeTradingAlgorithmBase):
attempts=self.attempts['synchronize_portfolio_attempts'],
sleeptime=self.attempts['retry_sleeptime'],
retry_exceptions=(ExchangeRequestError,),
cleanup=lambda e: log.warn(
'ordering again: {}'.format(e)
),
)
cleanup=lambda: log.warn('Ordering again.'))
log.info(
'got totals from exchanges, cash: {} positions: {}'.format(
cash, positions_value
@@ -807,11 +804,8 @@ class ExchangeTradingAlgorithmLive(ExchangeTradingAlgorithmBase):
attempts=self.attempts['get_open_orders_attempts'],
sleeptime=self.attempts['retry_sleeptime'],
retry_exceptions=(ExchangeRequestError,),
cleanup=lambda e: log.warn(
'fetching open orders again: {}'.format(e)
),
args=(asset,)
)
cleanup=lambda: log.warn('Fetching open orders again.'),
args=(asset,))
@api_method
def get_order(self, order_id, exchange_name):
@@ -836,11 +830,8 @@ class ExchangeTradingAlgorithmLive(ExchangeTradingAlgorithmBase):
attempts=self.attempts['get_order_attempts'],
sleeptime=self.attempts['retry_sleeptime'],
retry_exceptions=(ExchangeRequestError,),
cleanup=lambda e: log.warn(
'fetching orders again: {}'.format(e)
),
args=(order_id,)
)
cleanup=lambda: log.warn('Fetching orders again.'),
args=(order_id,))
@api_method
def cancel_order(self, order_param, exchange_name):
@@ -862,8 +853,5 @@ class ExchangeTradingAlgorithmLive(ExchangeTradingAlgorithmBase):
attempts=self.attempts['cancel_order_attempts'],
sleeptime=self.attempts['retry_sleeptime'],
retry_exceptions=(ExchangeRequestError,),
cleanup=lambda e: log.warn(
'cancelling order again: {}'.format(e)
),
args=(order_id,)
)
cleanup=lambda: log.warn('cancelling order again.'),
args=(order_id,))