update query cursors

Signed-off-by: Pranay Valson <[email protected]>
covalenthq · Jul 12, 2023 · 1e16763 · 1e16763
1 parent a3156d4
commit 1e16763
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/dbmanresult.py b/src/dbmanresult.py
@@ -80,7 +80,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_result_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 17635725;',
+                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 17643990;',
                                 (self.last_block_id,),
                             )
                         else:
@@ -103,7 +103,7 @@ def __main_loop(self):
                         # 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_result_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 17635725;',
+                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 17643990;',
                                 (self.last_block_id,),
                             )
                         else:

diff --git a/src/dbmanspecimen.py b/src/dbmanspecimen.py
@@ -80,7 +80,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 > 17388735;',
+                                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 > 17679865;',
                                 (self.last_block_id,),
                             )
                         else:
@@ -103,7 +103,7 @@ def __main_loop(self):
                         # 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 > 17388735;',
+                                r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 17679865;',
                                 (self.last_block_id,),
                             )
                         else: