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

Use group status for symbol loading

asyncify_input_modes
Tyler Goodlet 2021-06-18 09:38:14 -04:00
parent 37180a4e4e
commit 91209b7d6e
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
piker/ui/_chart.py
View File

@ -1245,10 +1245,11 @@ async def spawn_fsps(
linkedsplits: LinkedSplits, linkedsplits: LinkedSplits,
fsps: Dict[str, str], fsps: Dict[str, str],
sym, sym: str,
src_shm, src_shm: list,
brokermod, brokermod: ModuleType,
loglevel, group_status_key: str,
loglevel: str,
) -> None: ) -> None:
"""Start financial signal processing in subactor. """Start financial signal processing in subactor.
@ -1311,6 +1312,7 @@ async def spawn_fsps(
fsp_func_name, fsp_func_name,
display_name, display_name,
conf, conf,
group_status_key,
) )
# blocks here until all fsp actors complete # blocks here until all fsp actors complete
@ -1326,6 +1328,7 @@ async def run_fsp(
fsp_func_name: str, fsp_func_name: str,
display_name: str, display_name: str,
conf: Dict[str, Any], conf: Dict[str, Any],
group_status_key: str,
) -> None: ) -> None:
"""FSP stream chart update loop. """FSP stream chart update loop.
@ -1334,7 +1337,9 @@ async def run_fsp(
config map. config map.
""" """
done = linkedsplits.window().status_bar.open_status( done = linkedsplits.window().status_bar.open_status(
f'loading FSP: {display_name}..') f'loading {display_name}..',
group_key=group_status_key,
)
async with portal.open_stream_from( async with portal.open_stream_from(
@ -1548,7 +1553,10 @@ async def display_symbol_data(
''' '''
sbar = godwidget.window.status_bar sbar = godwidget.window.status_bar
loading_sym_done = sbar.open_status(f'loading {sym}.{provider}..') loading_sym_key = sbar.open_status(
f'loading {sym}.{provider} -> ',
group_key=True
)
# historical data fetch # historical data fetch
brokermod = brokers.get_brokermod(provider) brokermod = brokers.get_brokermod(provider)
@ -1597,8 +1605,6 @@ async def display_symbol_data(
add_label=False, add_label=False,
) )
loading_sym_done()
# size view to data once at outset # size view to data once at outset
chart._set_yrange() chart._set_yrange()
@ -1643,6 +1649,7 @@ async def display_symbol_data(
sym, sym,
ohlcv, ohlcv,
brokermod, brokermod,
loading_sym_key,
loglevel, loglevel,
) )
@ -1743,7 +1750,7 @@ async def _async_main(
# _style.style_ze_sheets(godwidget) # _style.style_ze_sheets(godwidget)
sbar = godwidget.window.status_bar sbar = godwidget.window.status_bar
starting_done = sbar.open_status('starting ze chartz...') starting_done = sbar.open_status('starting ze sexy chartz')
async with ( async with (
trio.open_nursery() as root_n, trio.open_nursery() as root_n,