checking exchange name with lower

This commit is contained in:
மனோஜ்குமார் பழனிச்சாமி 2022-04-02 11:18:50 +05:30
parent 161cd54237
commit 0b4dbe3906

View File

@ -85,7 +85,7 @@ def calculate_backoff(retrycount, max_retries):
def retrier_async(f): def retrier_async(f):
async def wrapper(*args, **kwargs): async def wrapper(*args, **kwargs):
count = kwargs.pop('count', API_RETRY_COUNT) count = kwargs.pop('count', API_RETRY_COUNT)
kucoin = args[0].name == "Kucoin" # Check if the exchange is KuCoin. kucoin = args[0].name.lower() == "kucoin" # Check if the exchange is KuCoin.
try: try:
return await f(*args, **kwargs) return await f(*args, **kwargs)
except TemporaryError as ex: except TemporaryError as ex:
@ -121,7 +121,7 @@ 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. kucoin = args[0].name.lower() == "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: