fix erroneous writer cli change introduced by prev commit

subsquid · Mar 26, 2024 · 8623f40 · 8623f40
1 parent 5a17a57
commit 8623f40
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/sqa/writer/cli.py b/sqa/writer/cli.py
@@ -113,19 +113,24 @@ def _start_prometheus_metrics(self):
     def _ingest(self) -> Iterable[list[Block]]:
         args = self._arguments()
         writer = self._writer()
+        first_block = self._sink().get_next_block()
+        last_block = args.last_block
+
+        if last_block is not None and first_block > last_block:
+            return
 
         if args.src:
             blocks = ingest_from_service(
                 args.src,
                 writer.get_block_height,
-                args.first_block,
-                args.last_block
+                first_block,
+                last_block
             )
         else:
             blocks = ingest_from_stdin(
                 writer.get_block_height,
-                args.first_block,
-                args.last_block
+                first_block,
+                last_block
             )
 
         pack = []