From 41990abdd9c311d29f035ac19d69be7685e4b1b0 Mon Sep 17 00:00:00 2001 From: Pranay Valson Date: Tue, 15 Aug 2023 15:11:46 -0700 Subject: [PATCH] retain older specimen contract event log Signed-off-by: Pranay Valson --- src/dbmanspecimen.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/dbmanspecimen.py b/src/dbmanspecimen.py index fd744c7..4a11191 100644 --- a/src/dbmanspecimen.py +++ b/src/dbmanspecimen.py @@ -85,7 +85,7 @@ def __main_loop(self): ) else: cur.execute( - r'SELECT * FROM chain_moonbeam_mainnet."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL;', + r'SELECT * FROM chain_moonbeam_mainnet."_proof_chain_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL;', (self.last_block_id,), ) outputs = cur.fetchall() @@ -108,7 +108,7 @@ def __main_loop(self): ) else: cur.execute( - r'SELECT * FROM chain_moonbeam_mainnet."_proof_chain_specimen_events" WHERE observer_chain_session_start_block_id > %s;', + r'SELECT * FROM chain_moonbeam_mainnet."_proof_chain_events" WHERE observer_chain_session_start_block_id > %s;', (self.last_block_id,), ) @@ -148,7 +148,7 @@ def __fetch_last_block(self): ) else: cur.execute( - r'SELECT observer_chain_session_start_block_id FROM chain_moonbeam_mainnet."_proof_chain_specimen_events" WHERE observer_chain_finalization_tx_hash IS NULL LIMIT 1' + r'SELECT observer_chain_session_start_block_id FROM chain_moonbeam_mainnet."_proof_chain_events" WHERE observer_chain_finalization_tx_hash IS NULL LIMIT 1' ) block_id = cur.fetchone() if block_id is not None: