From dba8457be94b022f48a4c421bb3c001e0f625d6f Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 7 Jan 2021 12:17:10 -0500 Subject: [PATCH] Trigger kraken sample increment after startup --- piker/brokers/kraken.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py index 2830f980..dfbf3c0f 100644 --- a/piker/brokers/kraken.py +++ b/piker/brokers/kraken.py @@ -1,5 +1,5 @@ # piker: trading gear for hackers -# Copyright (C) 2018-present Tyler Goodlet (in stewardship of piker0) +# Copyright (C) Tyler Goodlet (in stewardship for piker0) # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License as published by @@ -34,6 +34,7 @@ import tractor from ._util import resproc, SymbolNotFound, BrokerError from ..log import get_logger, get_console_log from ..data import ( + _buffer, # iterticks, attach_shm_array, get_shm_token, @@ -382,6 +383,9 @@ async def stream_quotes( # packetize as {topic: quote} yield {topic: quote} + # tell incrementer task it can start + _buffer.shm_incrementing(shm_token['shm_name']).set() + # keep start of last interval for volume tracking last_interval_start = ohlc_last.etime