diff --git a/piker/brokers/deribit/feed.py b/piker/brokers/deribit/feed.py index 25e9f605..f9258502 100644 --- a/piker/brokers/deribit/feed.py +++ b/piker/brokers/deribit/feed.py @@ -21,6 +21,7 @@ Deribit backend. from contextlib import asynccontextmanager as acm from datetime import datetime from typing import Any, Optional, Callable +from pprint import pformat import time import trio @@ -34,12 +35,20 @@ import numpy as np import tractor from piker.accounting import MktPair +from piker.accounting import ( + MktPair, + unpack_fqme, +) from piker.brokers import ( open_cached_client, NoData, ) +from piker._cacheables import ( + async_lifo_cache, +) from piker.log import get_logger, get_console_log from piker.data import ShmArray +from piker.data.validate import FeedInit from piker.brokers._util import ( BrokerError, DataUnavailable, @@ -57,6 +66,10 @@ from .api import ( piker_sym_to_cb_sym, cb_sym_to_deribit_inst, maybe_open_price_feed ) +from .venues import ( + Pair, + OptionPair, +) _spawn_kwargs = { 'infect_asyncio': True,