rename `.data._normalize` -> `.ticktools`

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,
     )

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

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,

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
 
 

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

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,
 )