From 32a6365b72a54ac38bb5b529ebc09d90555b5c7f Mon Sep 17 00:00:00 2001 From: David Lutterkort Date: Wed, 1 May 2024 15:53:59 -0700 Subject: [PATCH] graph: Include 'provider' in various firehose log messages --- graph/src/firehose/endpoints.rs | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/graph/src/firehose/endpoints.rs b/graph/src/firehose/endpoints.rs index 1da695fa1f6..b6d1de09086 100644 --- a/graph/src/firehose/endpoints.rs +++ b/graph/src/firehose/endpoints.rs @@ -314,7 +314,8 @@ impl FirehoseEndpoint { { debug!( logger, - "Connecting to firehose to retrieve block for cursor {}", cursor + "Connecting to firehose to retrieve block for cursor {}", cursor; + "provider" => self.provider.as_str(), ); let req = firehose::SingleBlockRequest { @@ -339,7 +340,8 @@ impl FirehoseEndpoint { where M: prost::Message + BlockchainBlock + Default + 'static, { - info!(logger, "Requesting genesis block from firehose"); + info!(logger, "Requesting genesis block from firehose"; + "provider" => self.provider.as_str()); // We use 0 here to mean the genesis block of the chain. Firehose // when seeing start block number 0 will always return the genesis @@ -358,7 +360,8 @@ impl FirehoseEndpoint { { debug!( logger, - "Connecting to firehose to retrieve block for number {}", number + "Connecting to firehose to retrieve block for number {}", number; + "provider" => self.provider.as_str(), ); let mut client = self.new_stream_client(); @@ -386,7 +389,8 @@ impl FirehoseEndpoint { let mut block_stream = response_stream.into_inner(); - debug!(logger, "Retrieving block(s) from firehose"); + debug!(logger, "Retrieving block(s) from firehose"; + "provider" => self.provider.as_str()); let mut latest_received_block: Option = None; while let Some(message) = block_stream.next().await {