Upgrade to DataFusion 12.0.0 (#53)

apache · Sep 16, 2022 · 259f2e4 · 259f2e4
1 parent adbcae3
commit 259f2e4
Show file tree

Hide file tree

Showing 10 changed files with 135 additions and 78 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -33,10 +33,10 @@ default = ["mimalloc"]
 [dependencies]
 tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread", "sync"] }
 rand = "0.7"
-pyo3 = { version = "~0.16.5", features = ["extension-module", "abi3", "abi3-py37"] }
-datafusion = { version = "^11.0.0", features = ["pyarrow"] }
-datafusion-expr = { version = "^11.0.0" }
-datafusion-common = { version = "^11.0.0", features = ["pyarrow"] }
+pyo3 = { version = "~0.17.1", features = ["extension-module", "abi3", "abi3-py37"] }
+datafusion = { version = "^12.0.0", features = ["pyarrow"] }
+datafusion-expr = { version = "^12.0.0" }
+datafusion-common = { version = "^12.0.0", features = ["pyarrow"] }
 uuid = { version = "0.8", features = ["v4"] }
 mimalloc = { version = "*", optional = true, default-features = false }
 async-trait = "0.1"

diff --git a/datafusion/tests/test_context.py b/datafusion/tests/test_context.py
@@ -133,7 +133,7 @@ def test_dataset_filter(ctx, capfd):
     # Make sure the filter was pushed down in Physical Plan
     df.explain()
     captured = capfd.readouterr()
-    assert "filter_expr=(((2 <= a) and (a <= 3)) and (b > 5))" in captured.out
+    assert "filter_expr=(((a >= 2) and (a <= 3)) and (b > 5))" in captured.out
 
     result = df.collect()