From 6e2328d3513d965726880985267d3646d832a592 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 3 Jan 2021 17:23:06 -0500 Subject: [PATCH] More comments? --- piker/ui/_chart.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/piker/ui/_chart.py b/piker/ui/_chart.py index e8670c30..2c14d683 100644 --- a/piker/ui/_chart.py +++ b/piker/ui/_chart.py @@ -59,7 +59,7 @@ from ..log import get_logger from ._exec import run_qtractor, current_screen from ._interaction import ChartView from .. import fsp -from .._ems import spawn_router_stream_alerts, _to_router +from .._ems import spawn_router_stream_alerts log = get_logger(__name__) @@ -868,12 +868,13 @@ async def _async_main( add_label=False, ) + # size view to data once at outset chart._set_yrange() # TODO: a data view api that makes this less shit chart._shm = ohlcv - # eventually we'll support some kind of n-compose syntax + # TODO: eventually we'll support some kind of n-compose syntax fsp_conf = { 'rsi': { 'period': 14, @@ -885,7 +886,8 @@ async def _async_main( } # make sure that the instrument supports volume history - # (sometimes this is not the case for some commodities and derivatives) + # (sometimes this is not the case for some commodities and + # derivatives) volm = ohlcv.array['volume'] if ( np.all(np.isin(volm, -1)) or @@ -904,7 +906,6 @@ async def _async_main( async with trio.open_nursery() as n: - # load initial fsp chain (otherwise known as "indicators") n.start_soon( spawn_fsps, @@ -925,6 +926,7 @@ async def _async_main( wap_in_history, ) + # spawn EMS actor-service router_send_chan = await n.start( spawn_router_stream_alerts, sym,