diff --git a/src/daft-local-execution/src/intermediate_ops/explode.rs b/src/daft-local-execution/src/intermediate_ops/explode.rs index 774be696a8..30ec8b02b5 100644 --- a/src/daft-local-execution/src/intermediate_ops/explode.rs +++ b/src/daft-local-execution/src/intermediate_ops/explode.rs @@ -28,7 +28,7 @@ impl IntermediateOperator for ExplodeOperator { &self, _idx: usize, input: &PipelineResultType, - _state: Option<&mut Box>, + _state: &IntermediateOperatorState, ) -> DaftResult { let out = input.as_data().explode(&self.to_explode)?; Ok(IntermediateOperatorResult::NeedMoreInput(Some(Arc::new(