diff --git a/piker/data/marketstore.py b/piker/data/marketstore.py
index 54dd0d7a..6f0d1bb9 100644
--- a/piker/data/marketstore.py
+++ b/piker/data/marketstore.py
@@ -139,6 +139,7 @@ def ingest(config, name, test_file, tl, url):
 
     async def main(tries):
         async with maybe_spawn_brokerd(
+            brokername=brokermod.name,
             tries=tries,
             loglevel=loglevel
         ) as portal: