Convert timeit thing to use print()

bar_select
Tyler Goodlet 2020-09-25 16:03:58 -04:00
parent 8832804bab
commit 155c3eef2a
2 changed files with 11 additions and 4 deletions

View File

@ -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'],

View File

@ -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)
)