diff --git a/piker/brokers/data.py b/piker/brokers/data.py index 9580add8..dbb76772 100644 --- a/piker/brokers/data.py +++ b/piker/brokers/data.py @@ -142,8 +142,7 @@ async def stream_poll_requests( # to the last quote received new = set(quote.items()) - set(last.items()) if new: - log.info( - f"New quote {quote['symbol']}:\n{new}") + log.info(f"New quote {symbol}:\n{new}") _cache[symbol] = quote # only ship diff updates and other required fields @@ -171,6 +170,8 @@ async def stream_poll_requests( # XXX: very questrade specific payload['size'] = quote['lastTradeSize'] + log.info(f"New paylod {symbol}:\n{payload}") + # XXX: we append to a list for the options case where the # subscription topic (key) is the same for all # expiries even though this is uncessary for the