diff --git a/src/daft-local-execution/src/intermediate_ops/actor_pool_project.rs b/src/daft-local-execution/src/intermediate_ops/actor_pool_project.rs index b05d91d64e..58f47d95ce 100644 --- a/src/daft-local-execution/src/intermediate_ops/actor_pool_project.rs +++ b/src/daft-local-execution/src/intermediate_ops/actor_pool_project.rs @@ -139,7 +139,7 @@ impl ActorPoolProjectOperator { } impl IntermediateOperator for ActorPoolProjectOperator { - #[instrument(skip_all, name = "ActorPoolProjectOperator::sink")] + #[instrument(skip_all, name = "ActorPoolProjectOperator::execute")] fn execute( &self, _idx: usize,