Use py::object (reinterpret_steal) for PyObject_CallObject return values to avoid leaking Python objects during scalar UDF execution.

Schwarf · Schwarf · commit 7acec08c71db · 2026-01-03T20:10:34.000+01:00
diff --git a/src/duckdb_py/python_udf.cpp b/src/duckdb_py/python_udf.cpp
@@ -326,7 +326,7 @@ static scalar_function_t CreateNativeFunction(PyObject *function, PythonExceptio
 			}
 
 			// Call the function
-			auto ret = PyObject_CallObject(function, bundled_parameters.ptr());
+			auto ret = py::reinterpret_steal<py::object>(PyObject_CallObject(function, bundled_parameters.ptr()));
 			if (ret == nullptr && PyErr_Occurred()) {
 				if (exception_handling == PythonExceptionHandling::FORWARD_ERROR) {
 					auto exception = py::error_already_set();

Original file line number	Diff line number	Diff line change
`@@ -326,7 +326,7 @@ static scalar_function_t CreateNativeFunction(PyObject *function, PythonExceptio`
`326`	`326`	`}`
`327`	`327`
`328`	`328`	`// Call the function`
`329`		`- auto ret = PyObject_CallObject(function, bundled_parameters.ptr());`
	`329`	`+ auto ret = py::reinterpret_steal<py::object>(PyObject_CallObject(function, bundled_parameters.ptr()));`
`330`	`330`	`if (ret == nullptr && PyErr_Occurred()) {`
`331`	`331`	`if (exception_handling == PythonExceptionHandling::FORWARD_ERROR) {`
`332`	`332`	`auto exception = py::error_already_set();`