update function signatures to use _bound versions

Author: emgeee

src/expr/window.rs

@@ -24,6 +24,7 @@ use std::fmt::{self, Display, Formatter};
 use crate::common::df_schema::PyDFSchema;
 use crate::errors::py_type_err;
 use crate::expr::logical_node::LogicalNode;
+use crate::expr::sort_expr::{py_sort_expr_list, PySortExpr};
 use crate::expr::PyExpr;
 use crate::sql::logical::PyLogicalPlan;
 
@@ -114,9 +115,9 @@ impl PyWindow {
     }
 
     /// Returns order by columns in a window function expression
-    pub fn get_sort_exprs(&self, expr: PyExpr) -> PyResult<Vec<PyExpr>> {
+    pub fn get_sort_exprs(&self, expr: PyExpr) -> PyResult<Vec<PySortExpr>> {
         match expr.expr.unalias() {
-            Expr::WindowFunction(WindowFunction { order_by, .. }) => py_expr_list(&order_by),
+            Expr::WindowFunction(WindowFunction { order_by, .. }) => py_sort_expr_list(&order_by),
             other => Err(not_window_function_err(other)),
         }
     }

src/udf.rs

@@ -20,6 +20,7 @@ use std::sync::Arc;
 use pyo3::{prelude::*, types::PyTuple};
 
 use datafusion::arrow::array::{make_array, Array, ArrayData, ArrayRef};
+use datafusion::arrow::pyarrow::FromPyArrow;
 use datafusion::arrow::datatypes::DataType;
 use datafusion::arrow::pyarrow::{PyArrowType, ToPyArrow};
 use datafusion::error::DataFusionError;
@@ -43,16 +44,15 @@ fn to_rust_function(func: PyObject) -> ScalarFunctionImplementation {
                     .iter()
                     .map(|arg| arg.into_data().to_pyarrow(py).unwrap())
                     .collect::<Vec<_>>();
-                let py_args = PyTuple::new(py, py_args);
+                let py_args = PyTuple::new_bound(py, py_args);
 
                 // 2. call function
                 let value = func
-                    .as_ref(py)
-                    .call(py_args, None)
+                    .call_bound(py, py_args, None)
                     .map_err(|e| DataFusionError::Execution(format!("{e:?}")))?;
 
                 // 3. cast to arrow::array::Array
-                let array_data = ArrayData::from_pyarrow(value).unwrap();
+                let array_data = ArrayData::from_pyarrow_bound(value.bind(py)).unwrap();
                 Ok(make_array(array_data))
             })
         },