remove @Retry decorator from shovels and fall back to base class error handling

Author: hey-michal

scraper_service/shovel_daily_balance/main.py

@@ -6,7 +6,6 @@
 from shared.shovel_base_class import ShovelBaseClass
 from shared.substrate import get_substrate_client, reconnect_substrate
 from shared.exceptions import DatabaseConnectionError, ShovelProcessingError
-from tenacity import retry, stop_after_attempt, wait_fixed
 
 logging.basicConfig(level=logging.INFO,
                     format="%(asctime)s %(process)d %(message)s")

scraper_service/shovel_daily_stake/main.py

@@ -7,7 +7,6 @@
 from shared.shovel_base_class import ShovelBaseClass
 from shared.substrate import reconnect_substrate
 from shared.exceptions import DatabaseConnectionError, ShovelProcessingError
-from tenacity import retry, stop_after_attempt, wait_fixed
 
 logging.basicConfig(level=logging.INFO,
                     format="%(asctime)s %(process)d %(message)s")

scraper_service/shovel_events/main.py

@@ -1,5 +1,3 @@
-from tenacity import retry, stop_after_attempt, wait_fixed
-
 from shared.block_metadata import get_block_metadata
 from shared.clickhouse.batch_insert import buffer_insert
 from shared.shovel_base_class import ShovelBaseClass

scraper_service/shovel_extrinsics/main.py

@@ -1,5 +1,3 @@
-from tenacity import retry, stop_after_attempt, wait_fixed
-
 from shared.block_metadata import get_block_metadata
 from shared.clickhouse.batch_insert import buffer_insert
 from shared.clickhouse.utils import (

scraper_service/shovel_subnets/main.py

@@ -1,5 +1,4 @@
 from shared.substrate import reconnect_substrate
-from tenacity import retry, stop_after_attempt, wait_fixed
 from shared.block_metadata import get_block_metadata
 from shared.clickhouse.batch_insert import buffer_insert
 from shared.shovel_base_class import ShovelBaseClass
@@ -23,11 +22,6 @@ def process_block(self, n):
             raise ShovelProcessingError(f"Failed to process block {n}: {str(e)}")
 
 
-@retry(
-    wait=wait_fixed(2),
-    before_sleep=lambda _: reconnect_substrate(),
-    stop=stop_after_attempt(15)
-)
 def do_process_block(n):
     try:
         # Create table if it doesn't exist