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