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

More comments?

basic_alerts
Tyler Goodlet 2021-01-03 17:23:06 -05:00
parent a3468fb915
commit 6e2328d351
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/ui/_chart.py
View File

@ -59,7 +59,7 @@ from ..log import get_logger
from ._exec import run_qtractor, current_screen from ._exec import run_qtractor, current_screen
from ._interaction import ChartView from ._interaction import ChartView
from .. import fsp from .. import fsp
from .._ems import spawn_router_stream_alerts, _to_router from .._ems import spawn_router_stream_alerts
log = get_logger(__name__) log = get_logger(__name__)
@ -868,12 +868,13 @@ async def _async_main(
add_label=False, add_label=False,
) )
# size view to data once at outset
chart._set_yrange() chart._set_yrange()
# TODO: a data view api that makes this less shit # TODO: a data view api that makes this less shit
chart._shm = ohlcv 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 = { fsp_conf = {
'rsi': { 'rsi': {
'period': 14, 'period': 14,
@ -885,7 +886,8 @@ async def _async_main(
} }
# make sure that the instrument supports volume history # 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'] volm = ohlcv.array['volume']
if ( if (
np.all(np.isin(volm, -1)) or np.all(np.isin(volm, -1)) or
@ -904,7 +906,6 @@ async def _async_main(
async with trio.open_nursery() as n: async with trio.open_nursery() as n:
# load initial fsp chain (otherwise known as "indicators") # load initial fsp chain (otherwise known as "indicators")
n.start_soon( n.start_soon(
spawn_fsps, spawn_fsps,
@ -925,6 +926,7 @@ async def _async_main(
wap_in_history, wap_in_history,
) )
# spawn EMS actor-service
router_send_chan = await n.start( router_send_chan = await n.start(
spawn_router_stream_alerts, spawn_router_stream_alerts,
sym, sym,