From 155c3eef2a384d3e295b05306db63d45d2c60954 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Fri, 25 Sep 2020 16:03:58 -0400 Subject: [PATCH] Convert timeit thing to use print() --- piker/brokers/kraken.py | 12 ++++++++++-- piker/ui/quantdom/utils.py | 3 +-- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py index 75333b9d..f2da2bb8 100644 --- a/piker/brokers/kraken.py +++ b/piker/brokers/kraken.py @@ -102,11 +102,18 @@ class Client: res.pop('last') bars = next(iter(res.values())) - # convert all fields to native types new_bars = [] - last_nz_vwap = None + + first = bars[0] + last_nz_vwap = first[-3] + if last_nz_vwap == 0: + # use close if vwap is zero + last_nz_vwap = first[-4] + + # convert all fields to native types for i, bar in enumerate(bars): # normalize weird zero-ed vwap values..cmon kraken.. + # indicates vwap didn't change since last bar vwap = float(bar[-3]) if vwap != 0: last_nz_vwap = vwap @@ -211,6 +218,7 @@ def normalize( @tractor.msg.pub async def stream_quotes( get_topics: Callable, + shared_array_token: Tuple[str, str, str], # These are the symbols not expected by the ws api # they are looked up inside this routine. symbols: List[str] = ['XBTUSD', 'XMRUSD'], diff --git a/piker/ui/quantdom/utils.py b/piker/ui/quantdom/utils.py index 0324b16e..af885cc4 100644 --- a/piker/ui/quantdom/utils.py +++ b/piker/ui/quantdom/utils.py @@ -50,8 +50,7 @@ def timeit(fn): def wrapper(*args, **kwargs): t = time.time() res = fn(*args, **kwargs) - logger = logging.getLogger('runtime') - logger.debug( + print( '%s.%s: %.4f sec' % (fn.__module__, fn.__qualname__, time.time() - t) )