From 86737c0da001f4f283b4825c27b4eca704a91404 Mon Sep 17 00:00:00 2001 From: Kevin Wang Date: Sun, 27 Oct 2024 23:25:37 -0700 Subject: [PATCH] rename ActorPoolProjectOperator::sink --- .../src/intermediate_ops/actor_pool_project.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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,