Pass broker name

2020-07-15 09:54:47 -04:00 · 2020-07-15 09:54:47 -04:00 · 3c4699abef
parent 78784a4bf3
commit 3c4699abef
1 changed files with 1 additions and 0 deletions
--- 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: