From 7c27eb85ae5a2322b7f0e93c84cdfdf4ca022958 Mon Sep 17 00:00:00 2001 From: Sergey Timoshin Date: Mon, 21 Jul 2025 15:18:32 +0100 Subject: [PATCH] refactor: skip large data args in tracing logs for batch processing --- forester/src/processor/v2/address.rs | 2 +- forester/src/processor/v2/state.rs | 12 ++++++++++-- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/forester/src/processor/v2/address.rs b/forester/src/processor/v2/address.rs index d6ef2e20c2..a8c2cafb7b 100644 --- a/forester/src/processor/v2/address.rs +++ b/forester/src/processor/v2/address.rs @@ -39,7 +39,7 @@ where Ok((stream, size)) } -#[instrument(level = "debug", skip(context), fields(tree = %context.merkle_tree))] +#[instrument(level = "debug", skip(context, merkle_tree_data), fields(tree = %context.merkle_tree))] pub(crate) async fn process_batch( context: &BatchContext, merkle_tree_data: ParsedMerkleTreeData, diff --git a/forester/src/processor/v2/state.rs b/forester/src/processor/v2/state.rs index e3d9df5ae3..e99c5439a2 100644 --- a/forester/src/processor/v2/state.rs +++ b/forester/src/processor/v2/state.rs @@ -71,7 +71,11 @@ where Ok((stream, size)) } -#[instrument(level = "debug", skip(context))] +#[instrument( + level = "debug", + skip(context, merkle_tree_data), + fields(merkle_tree = ?context.merkle_tree) +)] pub(crate) async fn perform_nullify( context: &BatchContext, merkle_tree_data: ParsedMerkleTreeData, @@ -104,7 +108,11 @@ pub(crate) async fn perform_nullify( Ok(()) } -#[instrument(level = "debug", skip(context))] +#[instrument( + level = "debug", + skip(context, merkle_tree_data, output_queue_data), + fields(merkle_tree = ?context.merkle_tree) +)] pub(crate) async fn perform_append( context: &BatchContext, merkle_tree_data: ParsedMerkleTreeData,