Necessary imports

jsonrpc_err_in_rent_task
Nelson Torres 2024-11-08 21:35:09 +00:00
parent d3ca571c0e
commit b4a9b86783
1 changed files with 13 additions and 0 deletions

View File

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