Pass broker name

2020-07-15 09:54:47 -04:00 · 2020-07-15 09:54:47 -04:00 · 7ea6f25993
parent d431ec20a8
commit 7ea6f25993
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: