From c7f95ac6b6c74fde8c5aa7c602319bb54e9b3b7a Mon Sep 17 00:00:00 2001 From: Leonardo Yvens Date: Mon, 26 Sep 2022 15:59:25 +0100 Subject: [PATCH] firehose: Dont use debug format on firehose errors --- graph/src/blockchain/firehose_block_ingestor.rs | 6 +++--- graph/src/blockchain/substreams_block_stream.rs | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/graph/src/blockchain/firehose_block_ingestor.rs b/graph/src/blockchain/firehose_block_ingestor.rs index 965272c0d35..54691bc5026 100644 --- a/graph/src/blockchain/firehose_block_ingestor.rs +++ b/graph/src/blockchain/firehose_block_ingestor.rs @@ -73,7 +73,7 @@ where latest_cursor = self.process_blocks(latest_cursor, stream).await } Err(e) => { - error!(self.logger, "Unable to connect to endpoint: {:?}", e); + error!(self.logger, "Unable to connect to endpoint: {:#}", e); } } @@ -89,7 +89,7 @@ where match self.chain_store.clone().chain_head_cursor() { Ok(cursor) => return cursor.unwrap_or_else(|| "".to_string()), Err(e) => { - error!(self.logger, "Fetching chain head cursor failed: {:?}", e); + error!(self.logger, "Fetching chain head cursor failed: {:#}", e); backoff.sleep_async().await; } @@ -128,7 +128,7 @@ where }; if let Err(e) = result { - error!(self.logger, "Process block failed: {:?}", e); + error!(self.logger, "Process block failed: {:#}", e); break; } diff --git a/graph/src/blockchain/substreams_block_stream.rs b/graph/src/blockchain/substreams_block_stream.rs index 291e14b210f..6581df743c9 100644 --- a/graph/src/blockchain/substreams_block_stream.rs +++ b/graph/src/blockchain/substreams_block_stream.rs @@ -264,7 +264,7 @@ fn stream_blocks>( metrics.observe_failed_connection(&mut connect_start); - error!(logger, "Unable to connect to endpoint: {:?}", e); + error!(logger, "Unable to connect to endpoint: {:#}", e); } } @@ -287,7 +287,7 @@ async fn process_substreams_response>( ) -> Result>, Error> { let response = match result { Ok(v) => v, - Err(e) => return Err(anyhow!("An error occurred while streaming blocks: {:?}", e)), + Err(e) => return Err(anyhow!("An error occurred while streaming blocks: {:#}", e)), }; match response.message {