pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

.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).
master
Tyler Goodlet 2023-05-22 11:52:36 -04:00
parent 60a6f3269c
commit e4e4cacef3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
piker/data/feed.py
View File

@ -815,7 +815,7 @@ async def open_feed(
for fqme in fqmes: for fqme in fqmes:
brokername, *_ = unpack_fqme(fqme) brokername, *_ = unpack_fqme(fqme)
bfqme = fqme.replace('.' + brokername, '') bs_fqme = fqme.replace('.' + brokername, '')
try: try:
mod = get_brokermod(brokername) mod = get_brokermod(brokername)
@ -823,7 +823,7 @@ async def open_feed(
mod = get_ingestormod(brokername) mod = get_ingestormod(brokername)
# built a per-provider map to instrument names # built a per-provider map to instrument names
providers.setdefault(mod, []).append(bfqme) providers.setdefault(mod, []).append(bs_fqme)
feed.mods[mod.name] = mod feed.mods[mod.name] = mod
# one actor per brokerd for now # one actor per brokerd for now
@ -903,7 +903,7 @@ async def open_feed(
for fqme, flume_msg in flumes_msg_dict.items(): for fqme, flume_msg in flumes_msg_dict.items():
flume = Flume.from_msg(flume_msg) flume = Flume.from_msg(flume_msg)
assert flume.symbol.fqme == fqme # assert flume.symbol.fqme == fqme
feed.flumes[fqme] = flume feed.flumes[fqme] = flume
# TODO: do we need this? # TODO: do we need this?