adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

kucoin temp fix for retrier

Browse Source 
Solves #6583
This commit is contained in:
மனோஜ்குமார் பழனிச்சாமி 2022-03-23 20:10:38 +05:30
parent e7418cdcdb
commit 161cd54237
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
freqtrade/exchange/common.py
View File

@ -121,19 +121,30 @@ def retrier(_func=None, retries=API_RETRY_COUNT):
@wraps(f) @wraps(f)
def wrapper(*args, **kwargs): def wrapper(*args, **kwargs):
count = kwargs.pop('count', retries) count = kwargs.pop('count', retries)
kucoin = args[0].name == "Kucoin" # Check if the exchange is KuCoin.
try: try:
return f(*args, **kwargs) return f(*args, **kwargs)
except (TemporaryError, RetryableOrderError) as ex: except (TemporaryError, RetryableOrderError) as ex:
msg = f'{f.__name__}() returned exception: "{ex}". ' msg = f'{f.__name__}() returned exception: "{ex}". '
if count > 0: if count > 0:
logger.warning(msg + f'Retrying still for {count} times.') msg += f'Retrying still for {count} times.'
count -= 1 count -= 1
kwargs.update({'count': count}) kwargs.update({'count': count})
if isinstance(ex, (DDosProtection, RetryableOrderError)): if isinstance(ex, (DDosProtection, RetryableOrderError)):
# increasing backoff if kucoin and "429000" in str(ex):
backoff_delay = calculate_backoff(count + 1, retries) # Temporary fix for 429000 error on kucoin
logger.info(f"Applying DDosProtection backoff delay: {backoff_delay}") # see https://github.com/freqtrade/freqtrade/issues/5700 for details.
time.sleep(backoff_delay) _get_logging_mixin().log_once(
f"Kucoin 429 error, avoid triggering DDosProtection backoff delay. "
f"{count} tries left before giving up", logmethod=logger.warning)
# Reset msg to avoid logging too many times.
msg = ''
else:
backoff_delay = calculate_backoff(count + 1, retries)
logger.info(f"Applying DDosProtection backoff delay: {backoff_delay}")
time.sleep(backoff_delay)
if msg:
logger.warning(msg)
return wrapper(*args, **kwargs) return wrapper(*args, **kwargs)
else: else:
logger.warning(msg + 'Giving up.') logger.warning(msg + 'Giving up.')