diff --git a/piker/clearing/_ems.py b/piker/clearing/_ems.py index c18631a6..b43d8fd1 100644 --- a/piker/clearing/_ems.py +++ b/piker/clearing/_ems.py @@ -47,12 +47,12 @@ from ._util import ( log, # sub-sys logger get_console_log, ) -from ..data._normalize import iterticks from ..accounting._mktinfo import ( unpack_fqme, dec_digits, ) from ..ui._notify import notify_from_ems_status_msg +from ..data import iterticks from ..data.types import Struct from ._messages import ( Order, @@ -67,7 +67,7 @@ from ._messages import ( ) if TYPE_CHECKING: - from ..data.feed import ( + from ..data import ( Feed, Flume, ) diff --git a/piker/clearing/_paper_engine.py b/piker/clearing/_paper_engine.py index ac5f3d3f..2df4eb4e 100644 --- a/piker/clearing/_paper_engine.py +++ b/piker/clearing/_paper_engine.py @@ -51,7 +51,7 @@ from ..accounting import ( open_trade_ledger, open_pps, ) -from ..data._normalize import iterticks +from ..data import iterticks from ..accounting import unpack_fqme from ._util import ( log, # sub-sys logger diff --git a/piker/data/__init__.py b/piker/data/__init__.py index 087928ec..6c621248 100644 --- a/piker/data/__init__.py +++ b/piker/data/__init__.py @@ -22,7 +22,7 @@ and storing data from your brokers as well as sharing live streams over a network. """ -from ._normalize import iterticks +from .ticktools import iterticks from ._sharedmem import ( maybe_open_shm_array, attach_shm_array, diff --git a/piker/data/_normalize.py b/piker/data/ticktools.py similarity index 100% rename from piker/data/_normalize.py rename to piker/data/ticktools.py diff --git a/piker/fsp/_momo.py b/piker/fsp/_momo.py index 488ae22c..d1463c22 100644 --- a/piker/fsp/_momo.py +++ b/piker/fsp/_momo.py @@ -24,7 +24,7 @@ import numpy as np from numba import jit, float64, optional, int64 from ._api import fsp -from ..data._normalize import iterticks +from ..data import iterticks from ..data._sharedmem import ShmArray diff --git a/piker/fsp/_volume.py b/piker/fsp/_volume.py index 06d0be91..594e80e4 100644 --- a/piker/fsp/_volume.py +++ b/piker/fsp/_volume.py @@ -20,7 +20,7 @@ import numpy as np from tractor.trionics._broadcast import AsyncReceiver from ._api import fsp -from ..data._normalize import iterticks +from ..data import iterticks from ..data._sharedmem import ShmArray from ._momo import _wma from ..log import get_logger diff --git a/piker/ui/_position.py b/piker/ui/_position.py index 0cf18136..90976a1e 100644 --- a/piker/ui/_position.py +++ b/piker/ui/_position.py @@ -56,8 +56,8 @@ from ..accounting._mktinfo import ( _derivs, ) -from ..data._normalize import iterticks -from ..data.feed import ( +from ..data import ( + iterticks, Feed, Flume, )