From 1e1676365db2bccc228cce4ef0e22d8b3a0773ec Mon Sep 17 00:00:00 2001 From: Pranay Valson Date: Wed, 12 Jul 2023 21:57:24 +0000 Subject: [PATCH] update query cursors Signed-off-by: Pranay Valson --- src/dbmanresult.py | 4 ++-- src/dbmanspecimen.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/dbmanresult.py b/src/dbmanresult.py index c8efc74..e21d466 100644 --- 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 index ff524ae..fd744c7 100644 --- 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: