From e4e4cacef3746442c700f5a3249054dff77b8af6 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Mon, 22 May 2023 11:52:36 -0400 Subject: [PATCH] .data.feed: Less stringency with fqme matching `Flume.mkt.fqme` might not be exactly the same as the local version now since we've had to add some hacks to certain backends (cough ib) to handle `MktPair.src` not being set as an `Asset` (yet). --- piker/data/feed.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/piker/data/feed.py b/piker/data/feed.py index 32ad49d0..0a8fd0f6 100644 --- a/piker/data/feed.py +++ b/piker/data/feed.py @@ -815,7 +815,7 @@ async def open_feed( for fqme in fqmes: brokername, *_ = unpack_fqme(fqme) - bfqme = fqme.replace('.' + brokername, '') + bs_fqme = fqme.replace('.' + brokername, '') try: mod = get_brokermod(brokername) @@ -823,7 +823,7 @@ async def open_feed( mod = get_ingestormod(brokername) # built a per-provider map to instrument names - providers.setdefault(mod, []).append(bfqme) + providers.setdefault(mod, []).append(bs_fqme) feed.mods[mod.name] = mod # one actor per brokerd for now @@ -903,7 +903,7 @@ async def open_feed( for fqme, flume_msg in flumes_msg_dict.items(): flume = Flume.from_msg(flume_msg) - assert flume.symbol.fqme == fqme + # assert flume.symbol.fqme == fqme feed.flumes[fqme] = flume # TODO: do we need this?