Merge pull request #963 from near/main

Prod Release 2 - 31/07/2024
near · Jul 31, 2024 · cc7fac4 · cc7fac4
2 parents c8b17d0 + 701ea19
commit cc7fac4
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs
@@ -131,7 +131,7 @@ impl BlockStream {
                     redis.get_last_processed_block(&config).await.unwrap();
 
                 loop {
-                    tokio::time::sleep(std::time::Duration::from_secs(15)).await;
+                    tokio::time::sleep(std::time::Duration::from_secs(120)).await;
 
                     let new_last_processed_block =
                         if let Ok(block) = redis.get_last_processed_block(&config).await {

diff --git a/coordinator/src/handlers/block_streams.rs b/coordinator/src/handlers/block_streams.rs
@@ -248,7 +248,7 @@ impl BlockStreamsHandler {
             let updated_at =
                 SystemTime::UNIX_EPOCH + Duration::from_secs(health.updated_at_timestamp_secs);
 
-            let stale = updated_at.elapsed().unwrap_or_default() > Duration::from_secs(60);
+            let stale = updated_at.elapsed().unwrap_or_default() > Duration::from_secs(180);
             let stalled = matches!(
                 health.processing_state.try_into(),
                 Ok(ProcessingState::Stalled)
@@ -257,7 +257,11 @@ impl BlockStreamsHandler {
             if !stale && !stalled {
                 return Ok(());
             } else {
-                tracing::info!(stale, stalled, "Restarting stalled block stream");
+                tracing::info!(
+                    stale,
+                    stalled,
+                    "Restarting stalled block stream after {RESTART_TIMEOUT_SECONDS} seconds"
+                );
             }
         } else {
             tracing::info!(

diff --git a/frontend/widgets/src/QueryApi.IndexerExplorer.jsx b/frontend/widgets/src/QueryApi.IndexerExplorer.jsx
@@ -74,9 +74,9 @@ const fetchIndexerData = () => {
           const sanitizedAccountID = author_account_id.replace(/\./g, '_');
           const key = `${sanitizedAccountID}/${indexer_name}`;
           return ({
+            ...(indexerMetaData.has(key) && indexerMetaData.get(key)),
             accountId: author_account_id,
             indexerName: indexer_name,
-            ...(indexerMetaData.has(key) && indexerMetaData.get(key))
           })
         });
         // sort by numQueries
@@ -158,8 +158,6 @@ const fetchIndexerMetadata = () => {
           original_deployment_date
         }) => {
           const indexer = {
-            accountId: indexer_account_id,
-            indexerName: indexer_name,
             lastDeploymentDate: last_deployment_date,
             numDeployements: num_deployements,
             numQueries: num_queries,