fix explode

Eventual-Inc · Oct 23, 2024 · 7aa7b61 · 7aa7b61
1 parent 994bb71
commit 7aa7b61
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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<dyn IntermediateOperatorState>>,
+        _state: &IntermediateOperatorState,
     ) -> DaftResult<IntermediateOperatorResult> {
         let out = input.as_data().explode(&self.to_explode)?;
         Ok(IntermediateOperatorResult::NeedMoreInput(Some(Arc::new(