set default io threads as 32

databendlabs · May 27, 2024 · f674835 · f674835
1 parent 0c59dc2
commit f674835
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/databend_udf/udf.py b/python/databend_udf/udf.py
@@ -61,7 +61,7 @@ class ScalarFunction(UserDefinedFunction):
     _skip_null: bool
 
     def __init__(
-        self, func, input_types, result_type, name=None, io_threads=None, skip_null=None
+        self, func, input_types, result_type, name=None, io_threads=32, skip_null=None
     ):
         self._func = func
         self._input_schema = pa.schema(