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

Raise errors, fix module script entry

its_happening
Tyler Goodlet 2020-07-15 13:26:48 -04:00
parent 5513d48c11
commit d6bd964fac
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/brokers/kraken.py
View File

@ -64,7 +64,9 @@ class Client:
pair: str = 'all', pair: str = 'all',
): ):
resp = await self._public('AssetPairs', {'pair': pair}) resp = await self._public('AssetPairs', {'pair': pair})
assert not resp['error'] err = resp['error']
if err:
raise BrokerError(err)
true_pair_key, data = next(iter(resp['result'].items())) true_pair_key, data = next(iter(resp['result'].items()))
return data return data
@ -113,7 +115,9 @@ async def get_client() -> Client:
async def stream_quotes( async def stream_quotes(
symbols: List[str] = ['BTC/USD', 'XRP/USD'], # These are the symbols not expected by the ws api
# they are looked up inside this routine.
symbols: List[str] = ['XBTUSD', 'XMRUSD'],
sub_type: str = 'ohlc', sub_type: str = 'ohlc',
) -> None: ) -> None:
"""Subscribe for ohlc stream of quotes for ``pairs``. """Subscribe for ohlc stream of quotes for ``pairs``.
@ -185,6 +189,6 @@ if __name__ == '__main__':
async def stream_ohlc(): async def stream_ohlc():
async for msg in stream_quotes(): async for msg in stream_quotes():
print(asdict(msg)) print(msg)
tractor.run(stream_ohlc) tractor.run(stream_ohlc)