rename ActorPoolProjectOperator::sink

Eventual-Inc · Oct 28, 2024 · 86737c0 · 86737c0
1 parent 803499a
commit 86737c0
Showing 1 changed file with 1 addition and 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
@@ -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,