diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py index cbfa3cbc..61658669 100644 --- a/piker/brokers/kraken.py +++ b/piker/brokers/kraken.py @@ -165,7 +165,7 @@ async def stream_quotes( volume: float # Accumulated volume within interval count: int # Number of trades within interval - # XXX: ugh, super hideous.. why doesn't + # XXX: ugh, super hideous.. needs built-in converters. def __post_init__(self): for field, val in self.__dataclass_fields__.items(): setattr(self, field, val.type(getattr(self, field))) diff --git a/piker/brokers/questrade.py b/piker/brokers/questrade.py index de0d1e7a..58b31fcf 100644 --- a/piker/brokers/questrade.py +++ b/piker/brokers/questrade.py @@ -1164,10 +1164,10 @@ async def stream_quotes( packetizer=partial( packetizer, formatter=formatter, - symboal_data=sd, + symbol_data=sd, ), - # actual func args + # actual target "streaming func" args get_quotes=get_quotes, diff_cached=diff_cached, rate=rate,