From 0e513599ebf9972e3fe5a7b952b6a098a28a1933 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Tue, 1 Sep 2020 13:24:08 -0400 Subject: [PATCH] Info log fsp output for now --- piker/fsp.py | 22 ++++------------------ 1 file changed, 4 insertions(+), 18 deletions(-) diff --git a/piker/fsp.py b/piker/fsp.py index 40f14f3a..f1418c2a 100644 --- a/piker/fsp.py +++ b/piker/fsp.py @@ -82,7 +82,7 @@ async def pull_and_process( filter_by_sym(symbol, stream), bars, ): - print(f"{fsp_func_name}: {processed}") + log.info(f"{fsp_func_name}: {processed}") yield processed @@ -105,27 +105,13 @@ async def latency( async for quote in source: ts = quote.get('broker_ts') if ts: - print( - f"broker time: {quote['broker_ts']}" - f"brokerd time: {quote['brokerd_ts']}" - ) + # This is codified in the per-broker normalization layer + # TODO: Add more measure points and diffs for full system + # stack tracing. value = quote['brokerd_ts'] - quote['broker_ts'] yield value -async def last( - source: 'TickStream[Dict[str, float]]', - ohlcv: np.ndarray -) -> AsyncIterator[np.ndarray]: - """Compute High-Low midpoint value. - """ - # deliver historical processed data first - yield ohlcv['close'] - - async for quote in source: - yield quote['close'] - - async def wma( source, #: AsyncStream[np.ndarray], ohlcv: np.ndarray, # price time-frame "aware"