From 8767751aaf86de6ae507ed351f866f10c5069839 Mon Sep 17 00:00:00 2001 From: Colin Ho Date: Fri, 25 Oct 2024 21:48:51 -0700 Subject: [PATCH] why are my tests not running --- .../src/intermediate_ops/intermediate_op.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs b/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs index f04f2a2cdf..086600ab88 100644 --- a/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs +++ b/src/daft-local-execution/src/intermediate_ops/intermediate_op.rs @@ -217,12 +217,12 @@ impl PipelineNode for IntermediateNode { } let (destination_sender, destination_receiver) = create_channel(1); let counting_sender = CountingSender::new(destination_sender, self.runtime_stats.clone()); - + let morsel_size = runtime_handle.determine_morsel_size(self.intermediate_op.morsel_size()); let (output_senders, mut output_receiver) = create_ordering_aware_receiver_channel(maintain_order, num_workers); let worker_sender = self.spawn_workers(num_workers, output_senders, runtime_handle, maintain_order); - let morsel_size = runtime_handle.determine_morsel_size(self.intermediate_op.morsel_size()); + runtime_handle.spawn( dispatch(child_result_receivers, worker_sender, morsel_size), self.intermediate_op.name(),