@on_ticker_update
def ticker_update(ticker: SPApiTicker):
    ticker_dict = _convert_from_ctype(ticker)
    self._ticker_queues[ticker_dict['ProdCode']].put(ticker_dict)
    api_logger.info(f'{ticker_dict}')
@on_ticker_update
def ticker_update(ticker: SPApiTicker):
    ticker_dict = _convert_from_ctype(ticker)
    self._ticker_queues[ticker_dict['ProdCode']].put(ticker_dict)
    api_logger.info(f'{ticker_dict}')