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

Only wait on backfill if provider supports timeframe

ib_1m_hist
Tyler Goodlet 2022-10-26 12:02:30 -04:00
parent a1a24da7b6
commit 286228c290
1 changed files with 7 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

@ -552,7 +552,7 @@ async def tsdb_backfill(
last_tsdb_dt, last_tsdb_dt,
None, None,
None, None,
bf_done, None,
) )
continue continue
@ -595,6 +595,7 @@ async def tsdb_backfill(
) = dts_per_tf[timeframe] ) = dts_per_tf[timeframe]
# sync to backend history task's query/load completion # sync to backend history task's query/load completion
if bf_done:
await bf_done.wait() await bf_done.wait()
# Load tsdb history into shm buffer (for display). # Load tsdb history into shm buffer (for display).
@ -1294,7 +1295,10 @@ async def install_brokerd_search(
async def search(text: str) -> dict[str, Any]: async def search(text: str) -> dict[str, Any]:
await stream.send(text) await stream.send(text)
try:
return await stream.receive() return await stream.receive()
except trio.EndOfChannel:
return {}
async with _search.register_symbol_search( async with _search.register_symbol_search(