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