async def _kline_loop_query(self, symbol, *args, **kwargs):
    (success, error) = (await self._rest_api.get_kline(symbol, 60, 2))
    if error:
        return (None, error)
    if (not success['success']):
        return (None, '_kline_loop_query error')
    result = success['result']
    k = result[0]
    self._update_kline(k, symbol)
async def _kline_loop_query(self, symbol, *args, **kwargs):
    (success, error) = (await self._rest_api.get_kline(symbol, 60, 2))
    if error:
        return (None, error)
    if (not success['success']):
        return (None, '_kline_loop_query error')
    result = success['result']
    k = result[0]
    self._update_kline(k, symbol)