diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py index 1416d6a7..cfd8751c 100644 --- a/piker/brokers/binance/feed.py +++ b/piker/brokers/binance/feed.py @@ -252,13 +252,16 @@ async def open_history_client( else: client.mkt_mode = 'spot' - # NOTE: always query using their native symbology! - mktid: str = mkt.bs_mktid - array = await client.bars( - mktid, + array: np.ndarray = await client.bars( + mkt=mkt, start_dt=start_dt, end_dt=end_dt, ) + if array.size == 0: + raise NoData( + f'No frame for {start_dt} -> {end_dt}\n' + ) + times = array['time'] if ( end_dt is None