Start piker.storage subsys: cross-(ts)db middlewares

Author: goodboy

piker/data/feed.py

@@ -865,9 +865,12 @@ async def manage_history(
         ):
             log.info('Found existing `marketstored`')
 
+            # TODO: make the module adhere to an attribute API-schema
+            # which can used here at this management layer.
             from ..service import marketstore
+            from .. import storage
             async with (
-                marketstore.open_storage_client(fqsn)as storage,
+                storage.open_storage_client(fqsn)as storage,
             ):
                 # TODO: drop returning the output that we pass in?
                 await bus.nursery.start(