piker/brokers/binance/feed.py

@@ -275,14 +275,12 @@ async def open_history_client(
                     f'{times}'
                 )
 
-            # XXX, debug any case where the latest 1m bar we get is
-            # already another "sample's-step-old"..
             if end_dt is None:
                 inow: int = round(time.time())
                 if (
-                    _time_step := (inow - times[-1])
+                    (inow - times[-1])
                     >
-                    timeframe * 2
+                    timeframe
                 ):
                     await tractor.pause()
 

piker/storage/cli.py

@@ -452,13 +452,7 @@ def ldshm(
                         )
                         # last chance manual overwrites in REPL
                         # await tractor.pause()
-                        if not aids:
-                            log.warning(
-                                f'No gaps were found !?\n'
-                                f'fqme: {fqme!r}\n'
-                                f'timeframe: {period_s!r}\n'
-                                f"WELL THAT'S GOOD NOOZ!\n"
-                            )
+                        assert aids
                         tf2aids[period_s] = aids
 
                 else: