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,