Set DF to 42.0.0

apache · Nov 9, 2024 · 3dfb266 · 3dfb266
1 parent c0d06e1
commit 3dfb266
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/context.rs b/src/context.rs
@@ -581,10 +581,8 @@ impl PySessionContext {
             let capsule = capsule.downcast::<PyCapsule>()?;
             // validate_pycapsule(capsule, "arrow_array_stream")?;
 
-            let provider = unsafe { FFI_TableProvider::from_raw(capsule.pointer() as _) };
+            let provider = unsafe { capsule.reference::<FFI_TableProvider>() };
             let provider = ForeignTableProvider::new(provider);
-            let schema = provider.schema();
-            println!("Got schema through TableProvider trait.");
 
             let _ = self.ctx.register_table(name, Arc::new(provider))?;
         }

diff --git a/src/udf.rs b/src/udf.rs
@@ -97,7 +97,7 @@ impl PyScalarUDF {
         let function = create_udf(
             name,
             input_types.0,
-            return_type.0,
+            Arc::new(return_type.0),
             parse_volatility(volatility)?,
             to_scalar_function_impl(func),
         );