File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -197,14 +197,14 @@ impl PyAggregateUDF {
197197 pub fn from_pycapsule(func: Bound<'_, PyAny>) -> PyDataFusionResult<Self> {
198198 if func.is_instance_of::<PyCapsule>() {
199199 let capsule = func.downcast::<PyCapsule>().map_err(py_datafusion_err)?;
200- let function = aggregate_udf_from_capsule(& capsule)?;
200+ let function = aggregate_udf_from_capsule(capsule)?;
201201 return Ok(Self { function });
202202 }
203203
204204 if func.hasattr("__datafusion_aggregate_udf__")? {
205205 let capsule = func.getattr("__datafusion_aggregate_udf__")?.call0()?;
206206 let capsule = capsule.downcast::<PyCapsule>().map_err(py_datafusion_err)?;
207- let function = aggregate_udf_from_capsule(& capsule)?;
207+ let function = aggregate_udf_from_capsule(capsule)?;
208208 return Ok(Self { function });
209209 }
210210
You can’t perform that action at this time.
0 commit comments