From 2995ea087bb6d89dcc591938e39383fd64c6b78d Mon Sep 17 00:00:00 2001 From: Alfredo Garcia Date: Wed, 17 Apr 2024 16:09:16 -0300 Subject: [PATCH] send ping to ES server before inserting data (#8409) --- zebra-state/src/service/finalized_state.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/zebra-state/src/service/finalized_state.rs b/zebra-state/src/service/finalized_state.rs index 41c76e64..7256d89d 100644 --- a/zebra-state/src/service/finalized_state.rs +++ b/zebra-state/src/service/finalized_state.rs @@ -502,6 +502,12 @@ impl FinalizedState { let network = self.network(); rt.block_on(async move { + // Send a ping to the server to check if it is available before inserting. + if client.ping().send().await.is_err() { + tracing::error!("Elasticsearch is not available, skipping block indexing"); + return; + } + let response = client .bulk(elasticsearch::BulkParts::Index( format!("zcash_{}", network.to_string().to_lowercase()).as_str(),