specify start block for debugging

indexer_app/tasks.py

@@ -25,13 +25,17 @@ async def indexer(network: str, from_block: int, to_block: int):
     lake_config.aws_secret_key = settings.AWS_SECRET_ACCESS_KEY
     _, streamer_messages_queue = streamer(lake_config)
     block_count = 0
-    
+
     while True:
         try:
             # streamer_message is the current block
             streamer_message = await streamer_messages_queue.get()
             block_count += 1
-            await cache_block_height("current_block_height", streamer_message.block.header.height, block_count) # current block height
+            await cache_block_height(
+                "current_block_height",
+                streamer_message.block.header.height,
+                block_count,
+            )  # current block height
             await handle_streamer_message(streamer_message)
         except Exception as e:
             logger.error(f"Error in streamer_messages_queue: {e}")
@@ -45,16 +49,19 @@ def listen_to_near_events():
 
     try:
         # Update below with desired network & block height
-        start_block = get_block_height('current_block_height')
-        # start_block = 104_963_982
+        # start_block = get_block_height('current_block_height')
+        start_block = 105_923_501  # manually setting for debugging TODO: remove this
         logger.info(f"what's the start block, pray tell? {start_block-1}")
-        loop.run_until_complete(indexer("mainnet", start_block-1, None))
+        loop.run_until_complete(indexer("mainnet", start_block - 1, None))
     finally:
         loop.close()
 
 
 from celery.signals import task_revoked
 
+
 @task_revoked.connect
 def on_task_revoked(request, terminated, signum, expired, **kwargs):
-    logger.info(f"Task {request.id} revoked; terminated={terminated}, signum={signum}, expired={expired}")
+    logger.info(
+        f"Task {request.id} revoked; terminated={terminated}, signum={signum}, expired={expired}"
+    )