diff --git a/piker/brokers/deribit/api.py b/piker/brokers/deribit/api.py index 03cc301e..c0ab1ed4 100644 --- a/piker/brokers/deribit/api.py +++ b/piker/brokers/deribit/api.py @@ -31,7 +31,7 @@ from typing import ( Callable, ) -import pendulum +from pendulum import now import trio from trio_typing import TaskStatus from rapidfuzz import process as fuzzy @@ -39,6 +39,7 @@ import numpy as np from tractor.trionics import ( broadcast_receiver, maybe_open_context + collapse_eg, ) from tractor import to_asyncio # XXX WOOPS XD @@ -432,6 +433,7 @@ async def get_client( ) -> Client: async with ( + collapse_eg(), trio.open_nursery() as n, open_jsonrpc_session( _testnet_ws_url, dtype=JSONRPCResult) as json_rpc