feat(tracing): add more tracing on I/O operations

Signed-off-by: Florian Valeye <[email protected]>

Author: fvaleye

crates/core/src/operations/delete.rs

@@ -308,6 +308,7 @@ async fn execute_non_empty_expr(
 }
 
 #[allow(clippy::too_many_arguments)]
+#[tracing::instrument(skip_all, fields(operation = "delete", version = snapshot.version(), table_uri = %log_store.root_uri()))]
 async fn execute(
     predicate: Option<Expr>,
     log_store: LogStoreRef,

crates/core/src/operations/merge/mod.rs

@@ -724,6 +724,7 @@ impl ExtensionPlanner for MergeMetricExtensionPlanner {
 }
 
 #[allow(clippy::too_many_arguments)]
+#[tracing::instrument(skip_all, fields(operation = "merge", version = snapshot.version(), table_uri = %log_store.root_uri()))]
 async fn execute(
     predicate: Expression,
     mut source: DataFrame,

crates/core/src/operations/update.rs

@@ -236,6 +236,7 @@ impl ExtensionPlanner for UpdateMetricExtensionPlanner {
 }
 
 #[allow(clippy::too_many_arguments)]
+#[tracing::instrument(skip_all, fields(operation = "update", version = snapshot.version(), table_uri = %log_store.root_uri()))]
 async fn execute(
     predicate: Option<Expression>,
     updates: HashMap<Column, Expression>,