We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4ea24b9 commit f85f7c6Copy full SHA for f85f7c6
1 file changed
python/src/lib.rs
@@ -3,9 +3,8 @@ use std::{
3
sync::{Arc, OnceLock},
4
};
5
6
-use datafusion::catalog::TableProvider;
+use datafusion::{catalog::TableProvider, execution::TaskContextProvider, prelude::SessionContext};
7
use datafusion_ffi::table_provider::FFI_TableProvider;
8
-use datafusion_python::context::PySessionContext;
9
use pyo3::{prelude::*, types::PyCapsule};
10
11
#[pyclass(module = "datafusion_table_providers._internal")]
@@ -34,8 +33,7 @@ impl RawTableProvider {
34
33
None
35
36
37
- let ctx = Arc::new(PySessionContext::new(None, runtime));
38
-
+ let ctx = Arc::new(SessionContext::default()) as Arc<dyn TaskContextProvider>;
39
let provider = FFI_TableProvider::new(
40
Arc::clone(&self.table),
41
self.supports_pushdown_filters,
0 commit comments