update block number offset

Signed-off-by: Pranay Valson <pranay.valson@gmail.com>
covalenthq · Jan 5, 2024 · f4578af · f4578af
1 parent fbd83fc
commit f4578af
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/dbmanspecimen.py b/src/dbmanspecimen.py
@@ -81,7 +81,7 @@ def __main_loop(self):
                         # we are catching up. So we only need to grab what we need to attempt for finalizing
                         if self.chain_table == "chain_moonbeam_moonbase_alpha":
                             cur.execute(
-                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 18621000;',
+                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 18781670;',
                                 (self.last_block_id,),
                             )
                         else:
@@ -91,7 +91,9 @@ def __main_loop(self):
                             )
                         outputs = cur.fetchall()
 
-                self.logger.info(f"Processing {len(outputs)} specimen proof-session records...")
+                self.logger.info(
+                    f"Processing {len(outputs)} specimen proof-session records..."
+                )
                 self._process_outputs(outputs)
 
                 self.caught_up = True
@@ -100,11 +102,13 @@ def __main_loop(self):
             while True:
                 with self.__connect() as conn:
                     with conn.cursor() as cur:
-                        self.logger.info(f"Incremental scan block_id={self.last_block_id}")
+                        self.logger.info(
+                            f"Incremental scan block_id={self.last_block_id}"
+                        )
                         # we need everything after last max block number
                         if self.chain_table == "chain_moonbeam_moonbase_alpha":
                             cur.execute(
-                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 18621000;',
+                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 18781670;',
                                 (self.last_block_id,),
                             )
                         else: