Merge pull request #4584 from withshubh/develop
fix: code quality issues
This commit is contained in:
commit
c7ee34687b
@ -177,7 +177,7 @@ def start_list_markets(args: Dict[str, Any], pairs_only: bool = False) -> None:
|
|||||||
# human-readable formats.
|
# human-readable formats.
|
||||||
print()
|
print()
|
||||||
|
|
||||||
if len(pairs):
|
if pairs:
|
||||||
if args.get('print_list', False):
|
if args.get('print_list', False):
|
||||||
# print data as a list, with human-readable summary
|
# print data as a list, with human-readable summary
|
||||||
print(f"{summary_str}: {', '.join(pairs.keys())}.")
|
print(f"{summary_str}: {', '.join(pairs.keys())}.")
|
||||||
|
@ -72,6 +72,5 @@ def copy_sample_files(directory: Path, overwrite: bool = False) -> None:
|
|||||||
if not overwrite:
|
if not overwrite:
|
||||||
logger.warning(f"File `{targetfile}` exists already, not deploying sample file.")
|
logger.warning(f"File `{targetfile}` exists already, not deploying sample file.")
|
||||||
continue
|
continue
|
||||||
else:
|
|
||||||
logger.warning(f"File `{targetfile}` exists already, overwriting.")
|
logger.warning(f"File `{targetfile}` exists already, overwriting.")
|
||||||
shutil.copy(str(sourcedir / source), str(targetfile))
|
shutil.copy(str(sourcedir / source), str(targetfile))
|
||||||
|
@ -140,7 +140,7 @@ def retrier(_func=None, retries=API_RETRY_COUNT):
|
|||||||
logger.warning('retrying %s() still for %s times', f.__name__, count)
|
logger.warning('retrying %s() still for %s times', f.__name__, count)
|
||||||
count -= 1
|
count -= 1
|
||||||
kwargs.update({'count': count})
|
kwargs.update({'count': count})
|
||||||
if isinstance(ex, DDosProtection) or isinstance(ex, RetryableOrderError):
|
if isinstance(ex, (DDosProtection, RetryableOrderError)):
|
||||||
# increasing backoff
|
# increasing backoff
|
||||||
backoff_delay = calculate_backoff(count + 1, retries)
|
backoff_delay = calculate_backoff(count + 1, retries)
|
||||||
logger.info(f"Applying DDosProtection backoff delay: {backoff_delay}")
|
logger.info(f"Applying DDosProtection backoff delay: {backoff_delay}")
|
||||||
|
@ -806,7 +806,7 @@ class Exchange:
|
|||||||
|
|
||||||
# Gather coroutines to run
|
# Gather coroutines to run
|
||||||
for pair, timeframe in set(pair_list):
|
for pair, timeframe in set(pair_list):
|
||||||
if (not ((pair, timeframe) in self._klines)
|
if (((pair, timeframe) not in self._klines)
|
||||||
or self._now_is_time_to_refresh(pair, timeframe)):
|
or self._now_is_time_to_refresh(pair, timeframe)):
|
||||||
input_coroutines.append(self._async_get_candle_history(pair, timeframe,
|
input_coroutines.append(self._async_get_candle_history(pair, timeframe,
|
||||||
since_ms=since_ms))
|
since_ms=since_ms))
|
||||||
@ -958,7 +958,7 @@ class Exchange:
|
|||||||
while True:
|
while True:
|
||||||
t = await self._async_fetch_trades(pair,
|
t = await self._async_fetch_trades(pair,
|
||||||
params={self._trades_pagination_arg: from_id})
|
params={self._trades_pagination_arg: from_id})
|
||||||
if len(t):
|
if t:
|
||||||
# Skip last id since its the key for the next call
|
# Skip last id since its the key for the next call
|
||||||
trades.extend(t[:-1])
|
trades.extend(t[:-1])
|
||||||
if from_id == t[-1][1] or t[-1][0] > until:
|
if from_id == t[-1][1] or t[-1][0] > until:
|
||||||
@ -990,7 +990,7 @@ class Exchange:
|
|||||||
# DEFAULT_TRADES_COLUMNS: 1 -> id
|
# DEFAULT_TRADES_COLUMNS: 1 -> id
|
||||||
while True:
|
while True:
|
||||||
t = await self._async_fetch_trades(pair, since=since)
|
t = await self._async_fetch_trades(pair, since=since)
|
||||||
if len(t):
|
if t:
|
||||||
since = t[-1][0]
|
since = t[-1][0]
|
||||||
trades.extend(t)
|
trades.extend(t)
|
||||||
# Reached the end of the defined-download period
|
# Reached the end of the defined-download period
|
||||||
|
@ -611,7 +611,7 @@ class LocalTrade():
|
|||||||
|
|
||||||
else:
|
else:
|
||||||
# Not used during backtesting, but might be used by a strategy
|
# Not used during backtesting, but might be used by a strategy
|
||||||
sel_trades = [trade for trade in LocalTrade.trades + LocalTrade.trades_open]
|
sel_trades = list(LocalTrade.trades + LocalTrade.trades_open)
|
||||||
|
|
||||||
if pair:
|
if pair:
|
||||||
sel_trades = [trade for trade in sel_trades if trade.pair == pair]
|
sel_trades = [trade for trade in sel_trades if trade.pair == pair]
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
Performance pair list filter
|
Performance pair list filter
|
||||||
"""
|
"""
|
||||||
import logging
|
import logging
|
||||||
from typing import Any, Dict, List
|
from typing import Dict, List
|
||||||
|
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
|
|
||||||
@ -15,11 +15,6 @@ logger = logging.getLogger(__name__)
|
|||||||
|
|
||||||
class PerformanceFilter(IPairList):
|
class PerformanceFilter(IPairList):
|
||||||
|
|
||||||
def __init__(self, exchange, pairlistmanager,
|
|
||||||
config: Dict[str, Any], pairlistconfig: Dict[str, Any],
|
|
||||||
pairlist_pos: int) -> None:
|
|
||||||
super().__init__(exchange, pairlistmanager, config, pairlistconfig, pairlist_pos)
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def needstickers(self) -> bool:
|
def needstickers(self) -> bool:
|
||||||
"""
|
"""
|
||||||
|
@ -1,7 +1,6 @@
|
|||||||
|
|
||||||
import logging
|
import logging
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Any, Dict
|
|
||||||
|
|
||||||
from freqtrade.persistence import Trade
|
from freqtrade.persistence import Trade
|
||||||
from freqtrade.plugins.protections import IProtection, ProtectionReturn
|
from freqtrade.plugins.protections import IProtection, ProtectionReturn
|
||||||
@ -15,9 +14,6 @@ class CooldownPeriod(IProtection):
|
|||||||
has_global_stop: bool = False
|
has_global_stop: bool = False
|
||||||
has_local_stop: bool = True
|
has_local_stop: bool = True
|
||||||
|
|
||||||
def __init__(self, config: Dict[str, Any], protection_config: Dict[str, Any]) -> None:
|
|
||||||
super().__init__(config, protection_config)
|
|
||||||
|
|
||||||
def _reason(self) -> str:
|
def _reason(self) -> str:
|
||||||
"""
|
"""
|
||||||
LockReason to use
|
LockReason to use
|
||||||
|
@ -196,9 +196,9 @@ class StrategyResolver(IResolver):
|
|||||||
strategy._populate_fun_len = len(getfullargspec(strategy.populate_indicators).args)
|
strategy._populate_fun_len = len(getfullargspec(strategy.populate_indicators).args)
|
||||||
strategy._buy_fun_len = len(getfullargspec(strategy.populate_buy_trend).args)
|
strategy._buy_fun_len = len(getfullargspec(strategy.populate_buy_trend).args)
|
||||||
strategy._sell_fun_len = len(getfullargspec(strategy.populate_sell_trend).args)
|
strategy._sell_fun_len = len(getfullargspec(strategy.populate_sell_trend).args)
|
||||||
if any([x == 2 for x in [strategy._populate_fun_len,
|
if any(x == 2 for x in [strategy._populate_fun_len,
|
||||||
strategy._buy_fun_len,
|
strategy._buy_fun_len,
|
||||||
strategy._sell_fun_len]]):
|
strategy._sell_fun_len]):
|
||||||
strategy.INTERFACE_VERSION = 1
|
strategy.INTERFACE_VERSION = 1
|
||||||
|
|
||||||
return strategy
|
return strategy
|
||||||
|
Loading…
Reference in New Issue
Block a user