pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Another fqsn -> fqme rename

pre_overruns_ctxcancelled
Tyler Goodlet 2023-04-10 22:27:29 -04:00
parent 3edc95dda0
commit 7786ffa889
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
piker/data/feed.py
View File

@ -941,7 +941,7 @@ class BackendInitMsg(Struct, frozen=True):
from each backend broker/data provider. from each backend broker/data provider.
''' '''
fqsn: str fqme: str
symbol_info: dict | None = None symbol_info: dict | None = None
mkt_info: MktPair | None = None mkt_info: MktPair | None = None
shm_write_opts: dict[str, Any] | None = None shm_write_opts: dict[str, Any] | None = None
@ -1284,7 +1284,9 @@ async def open_feed_bus(
# sync feed subscribers with flume handles # sync feed subscribers with flume handles
await ctx.started( await ctx.started(
{fqsn: flume.to_msg() for fqsn, flume in flumes.items()} {fqsn: flume.to_msg()
for fqsn, flume in flumes.items()
}
) )
if not start_stream: if not start_stream: