Merge pull request #182 from PotLock/testnet

testnet -> dev

Author: Prometheo

base/settings.py

@@ -62,6 +62,7 @@
 RECLAIM_APP_ID = os.environ.get("PL_RECLAIM_APP_ID")
 RECLAIM_APP_SECRET = os.environ.get("PL_RECLAIM_APP_SECRET")
 RECLAIM_TWITTER_PROVIDER_ID = os.environ.get("PL_RECLAIM_TWITTER_PROVIDER_ID")
+INDEXER_STREAMER_WAIT_TIME = os.environ.get("PL_INDEXER_STREAMER_WAIT_TIME", 300)  # in seconds
 
 # POTLOCK_TLA = "potlock.testnet" if ENVIRONMENT == "testnet" else "potlock.near"
 POTLOCK_TLA = "potlock.testnet" if ENVIRONMENT == "testnet" else ("staging.potlock.near" if ENVIRONMENT == "dev" else "potlock.near")

indexer_app/tasks.py

@@ -52,7 +52,7 @@ async def indexer(from_block: int, to_block: int):
             # Log time before fetching a new block
             fetch_start_time = time.time()
             # streamer_message is the current block
-            streamer_message = await asyncio.wait_for(streamer_messages_queue.get(), 30)
+            streamer_message = await asyncio.wait_for(streamer_messages_queue.get(), settings.INDEXER_STREAMER_WAIT_TIME)
             fetch_end_time = time.time()
             logger.info(
                 f"Time to fetch new block: {fetch_end_time - fetch_start_time:.4f} seconds"