retain older specimen contract event log

Signed-off-by: Pranay Valson <pranay.valson@gmail.com>
covalenthq · Aug 15, 2023 · 41990ab · 41990ab
1 parent e65082a
commit 41990ab
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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: