pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Allow passing in tbk keys to query

its_happening
Tyler Goodlet 2020-06-24 14:23:37 -04:00
parent 56132d1fcc
commit 72a3149dc7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
piker/data/marketstore.py
View File

@ -178,7 +178,7 @@ def ingest(config, name, test_file, tl, url):
# since last quote) # since last quote)
new_vol = fmt_quote.get('volume', None) new_vol = fmt_quote.get('volume', None)
if new_vol is None: if new_vol is None:
log.info(f"NO trades for {symbol}") log.debug(f"No fills for {symbol}")
if new_vol == quote_cache.get('volume'): if new_vol == quote_cache.get('volume'):
log.error( log.error(
f"{symbol}: got same volume as last quote?") f"{symbol}: got same volume as last quote?")
@ -222,9 +222,9 @@ def ms_shell(config, name, tl, url):
""" """
client = pymkts.Client(url) client = pymkts.Client(url)
def query(name): def query(name, tbk=_tick_tbk_ids):
return client.query( return client.query(
pymkts.Params(name, *_tick_tbk_ids)).first().df() pymkts.Params(name, *tbk)).first().df()
# causes crash # causes crash
# client.query(pymkts.Params(symbol, '*', 'OHCLV' # client.query(pymkts.Params(symbol, '*', 'OHCLV'