Skip to content

Commit 8414157

Browse files
lint: allow(deprecated) for make_scalar_function
1 parent 2dda4ff commit 8414157

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/udf.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ use datafusion::arrow::array::{make_array, Array, ArrayData, ArrayRef};
2323
use datafusion::arrow::datatypes::DataType;
2424
use datafusion::arrow::pyarrow::{FromPyArrow, PyArrowType, ToPyArrow};
2525
use datafusion::error::DataFusionError;
26-
use datafusion::physical_plan::functions::make_scalar_function;
2726
use datafusion::physical_plan::udf::ScalarUDF;
2827
use datafusion_expr::create_udf;
2928
use datafusion_expr::function::ScalarFunctionImplementation;
@@ -35,7 +34,8 @@ use crate::utils::parse_volatility;
3534
/// that expects pyarrow arrays. This is more efficient as it performs
3635
/// a zero-copy of the contents.
3736
fn to_rust_function(func: PyObject) -> ScalarFunctionImplementation {
38-
make_scalar_function(
37+
#[allow(deprecated)]
38+
datafusion::physical_plan::functions::make_scalar_function(
3939
move |args: &[ArrayRef]| -> Result<ArrayRef, DataFusionError> {
4040
Python::with_gil(|py| {
4141
// 1. cast args to Pyarrow arrays

0 commit comments

Comments
 (0)