compute_value, type)
return amounts
- def fetch_balances(self, tag=None, add_portfolio=False,
+ def fetch_balances(self, tag=None, add_portfolio=False, liquidity="medium",
checkpoint=None, log_tickers=False, add_usdt=False,
ticker_currency="BTC", ticker_compute_value="average", ticker_type="total"):
all_balances = self.market.ccxt.fetch_all_balances()
currency in self.all:
self.all[currency] = portfolio.Balance(currency, balance)
if add_portfolio:
- for currency in Portfolio.repartition(from_cache=True):
+ for currency in Portfolio.repartition(from_cache=True, liquidity=liquidity):
self.all.setdefault(currency, portfolio.Balance(currency, {}))
if add_usdt:
self.all.setdefault("USDT", portfolio.Balance("USDT", {}))
elif delta < datetime.timedelta(days=1):
return 60*60
else:
- raise "Too long waiting"
+ raise Exception("Too long waiting")
@classmethod
def start_worker(cls):
cls.report.print_log("[Worker] Fetching cryptoportfolio")
cls.get_cryptoportfolio(refetch=True)
cls.callback.set()
- time.sleep(cls.next_wait_time())
+ try:
+ time.sleep(cls.next_wait_time())
+ except Exception:
+ cls.stop_worker()
@classmethod
def stop_worker(cls):
if cls.data.get() is not None and not refetch:
return
if cls.worker is not None and not cls.is_worker_thread():
+ if not cls.worker_started:
+ raise Exception("Portfolio worker is down and no usable data is present")
cls.notify_and_wait()
return
try: