diff --git a/Cargo.lock b/Cargo.lock
index 287c3bc..71d72c0 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -170,8 +170,7 @@ checksum = "7c02d123df017efcdfbd739ef81735b36c5ba83ec3c59c80a9d7ecc718f92e50"
 [[package]]
 name = "arrow"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d441fdda254b65f3e9025910eb2c2066b6295d9c8ed409522b8d2ace1ff8574c"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-arith",
  "arrow-array",
@@ -191,8 +190,7 @@ dependencies = [
 [[package]]
 name = "arrow-arith"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ced5406f8b720cc0bc3aa9cf5758f93e8593cda5490677aa194e4b4b383f9a59"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -205,8 +203,7 @@ dependencies = [
 [[package]]
 name = "arrow-array"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "772bd34cacdda8baec9418d80d23d0fb4d50ef0735685bd45158b83dfeb6e62d"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "ahash",
  "arrow-buffer",
@@ -215,7 +212,7 @@ dependencies = [
  "chrono",
  "chrono-tz",
  "half",
- "hashbrown 0.16.1",
+ "hashbrown 0.17.0",
  "num-complex",
  "num-integer",
  "num-traits",
@@ -224,8 +221,7 @@ dependencies = [
 [[package]]
 name = "arrow-buffer"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "898f4cf1e9598fdb77f356fdf2134feedfd0ee8d5a4e0a5f573e7d0aec16baa4"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "bytes",
  "half",
@@ -236,8 +232,7 @@ dependencies = [
 [[package]]
 name = "arrow-cast"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b0127816c96533d20fc938729f48c52d3e48f99717e7a0b5ade77d742510736d"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -258,8 +253,7 @@ dependencies = [
 [[package]]
 name = "arrow-csv"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ca025bd0f38eeecb57c2153c0123b960494138e6a957bbda10da2b25415209fe"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-cast",
@@ -273,8 +267,7 @@ dependencies = [
 [[package]]
 name = "arrow-data"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "42d10beeab2b1c3bb0b53a00f7c944a178b622173a5c7bcabc3cb45d90238df4"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-buffer",
  "arrow-schema",
@@ -286,8 +279,7 @@ dependencies = [
 [[package]]
 name = "arrow-ipc"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "609a441080e338147a84e8e6904b6da482cefb957c5cdc0f3398872f69a315d0"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -302,14 +294,14 @@ dependencies = [
 [[package]]
 name = "arrow-json"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6ead0914e4861a531be48fe05858265cf854a4880b9ed12618b1d08cba9bebc8"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
  "arrow-cast",
- "arrow-data",
+ "arrow-ord",
  "arrow-schema",
+ "arrow-select",
  "chrono",
  "half",
  "indexmap",
@@ -326,8 +318,7 @@ dependencies = [
 [[package]]
 name = "arrow-ord"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "763a7ba279b20b52dad300e68cfc37c17efa65e68623169076855b3a9e941ca5"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -339,8 +330,7 @@ dependencies = [
 [[package]]
 name = "arrow-row"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e14fe367802f16d7668163ff647830258e6e0aeea9a4d79aaedf273af3bdcd3e"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -352,8 +342,7 @@ dependencies = [
 [[package]]
 name = "arrow-schema"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c30a1365d7a7dc50cc847e54154e6af49e4c4b0fddc9f607b687f29212082743"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "serde_core",
  "serde_json",
@@ -362,8 +351,7 @@ dependencies = [
 [[package]]
 name = "arrow-select"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "78694888660a9e8ac949853db393af2a8b8fc82c19ce333132dfa2e72cc1a7fe"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "ahash",
  "arrow-array",
@@ -376,8 +364,7 @@ dependencies = [
 [[package]]
 name = "arrow-string"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "61e04a01f8bb73ce54437514c5fd3ee2aa3e8abe4c777ee5cc55853b1652f79e"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -2036,6 +2023,12 @@ dependencies = [
  "foldhash 0.2.0",
 ]
 
+[[package]]
+name = "hashbrown"
+version = "0.17.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4f467dd6dccf739c208452f8014c75c18bb8301b050ad1cfb27153803edb0f51"
+
 [[package]]
 name = "heck"
 version = "0.5.0"
@@ -2657,8 +2650,7 @@ dependencies = [
 [[package]]
 name = "parquet"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7d3f9f2205199603564127932b89695f52b62322f541d0fc7179d57c2e1c9877"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "ahash",
  "arrow-array",
@@ -2674,7 +2666,7 @@ dependencies = [
  "flate2",
  "futures",
  "half",
- "hashbrown 0.16.1",
+ "hashbrown 0.17.0",
  "lz4_flex",
  "num-bigint",
  "num-integer",
@@ -2693,13 +2685,14 @@ dependencies = [
 [[package]]
 name = "parquet-variant"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2bf493f3c9ddd984d0efb019f67343e4aa4bab893931f6a14b82083065dc3d28"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
+ "arrow",
  "arrow-schema",
  "chrono",
  "half",
  "indexmap",
+ "num-traits",
  "simdutf8",
  "uuid",
 ]
@@ -2707,8 +2700,7 @@ dependencies = [
 [[package]]
 name = "parquet-variant-compute"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6ac038d46a503a7d563b4f5df5802c4315d5343d009feab195d15ac512b4cb27"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow",
  "arrow-schema",
@@ -2724,8 +2716,7 @@ dependencies = [
 [[package]]
 name = "parquet-variant-json"
 version = "58.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "015a09c2ffe5108766c7c1235c307b8a3c2ea64eca38455ba1a7f3a7f32f16e2"
+source = "git+https://github.com/pydantic/arrow-rs.git?branch=main#a3dbc154af4b9f6aebf38b4e5343fed176449a8e"
 dependencies = [
  "arrow-schema",
  "base64",
@@ -4364,3 +4355,178 @@ dependencies = [
  "cc",
  "pkg-config",
 ]
+
+[[patch.unused]]
+name = "datafusion"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-catalog"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-catalog-listing"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-common"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-common-runtime"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource-arrow"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource-avro"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource-csv"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource-json"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-datasource-parquet"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-doc"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-execution"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-expr"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-expr-common"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-aggregate"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-aggregate-common"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-nested"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-table"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-window"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-functions-window-common"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-macros"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-optimizer"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-physical-expr"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-physical-expr-adapter"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-physical-expr-common"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-physical-optimizer"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-physical-plan"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-pruning"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-session"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-spark"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-sql"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-sqllogictest"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
+
+[[patch.unused]]
+name = "datafusion-substrait"
+version = "53.1.0"
+source = "git+https://github.com/pydantic/datafusion.git?branch=pydantic-main#15bb745c3aab36c48fffe31751d66802a2e12200"
diff --git a/Cargo.toml b/Cargo.toml
index 395be17..407d22d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -26,3 +26,59 @@ indicatif = "0.18"
 env_logger = "0.11"
 insta = "1.43.2"
 rustyline = { version = "14.0", features = ["derive"] }
+
+[patch.crates-io]
+# pydantic forks
+arrow = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-arith = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-array = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-buffer = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-cast = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-csv = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-data = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-ipc = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-json = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-ord = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-row = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-schema = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-select = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-string = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant-compute = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant-json = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+datafusion = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-catalog = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-catalog-listing = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-common-runtime = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-arrow = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-avro = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-csv = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-json = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-parquet = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-doc = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-execution = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-expr = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-expr-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-aggregate = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-aggregate-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-nested = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-table = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-window = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-window-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-macros = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-optimizer = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr-adapter = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-optimizer = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-plan = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-pruning = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-session = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-spark = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-sql = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-sqllogictest = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-substrait = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
diff --git a/src/cast_to_variant.rs b/src/cast_to_variant.rs
index 8513d7e..b311db3 100644
--- a/src/cast_to_variant.rs
+++ b/src/cast_to_variant.rs
@@ -157,9 +157,6 @@ impl CastToVariantUdf {
 }
 
 impl ScalarUDFImpl for CastToVariantUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "cast_to_variant"
diff --git a/src/impl_variant_get.rs b/src/impl_variant_get.rs
index aa46d74..911aa33 100644
--- a/src/impl_variant_get.rs
+++ b/src/impl_variant_get.rs
@@ -23,9 +23,6 @@ macro_rules! impl_variant_get_typed {
         }
 
         impl ScalarUDFImpl for $struct_name {
-            fn as_any(&self) -> &dyn std::any::Any {
-                self
-            }
 
             fn name(&self) -> &str {
                 $func_name
diff --git a/src/is_variant_null.rs b/src/is_variant_null.rs
index ac6a6d0..b8c4ad4 100644
--- a/src/is_variant_null.rs
+++ b/src/is_variant_null.rs
@@ -27,9 +27,6 @@ impl Default for IsVariantNullUdf {
 }
 
 impl ScalarUDFImpl for IsVariantNullUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "is_variant_null"
diff --git a/src/json_to_variant.rs b/src/json_to_variant.rs
index d50e07e..e0578e1 100644
--- a/src/json_to_variant.rs
+++ b/src/json_to_variant.rs
@@ -38,9 +38,6 @@ impl Default for JsonToVariantUdf {
 }
 
 impl ScalarUDFImpl for JsonToVariantUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "json_to_variant"
diff --git a/src/variant_get.rs b/src/variant_get.rs
index 0468ddb..205e6df 100644
--- a/src/variant_get.rs
+++ b/src/variant_get.rs
@@ -335,9 +335,6 @@ impl Default for VariantGetUdf {
 }
 
 impl ScalarUDFImpl for VariantGetUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_get"
@@ -392,9 +389,6 @@ impl Default for VariantGetFieldUdf {
 }
 
 impl ScalarUDFImpl for VariantGetFieldUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_get_field"
diff --git a/src/variant_list_construct.rs b/src/variant_list_construct.rs
index 4a265e7..6afa33f 100644
--- a/src/variant_list_construct.rs
+++ b/src/variant_list_construct.rs
@@ -28,9 +28,6 @@ impl Default for VariantListConstruct {
 }
 
 impl ScalarUDFImpl for VariantListConstruct {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_construct"
diff --git a/src/variant_list_delete.rs b/src/variant_list_delete.rs
index 5d76b30..ec232f6 100644
--- a/src/variant_list_delete.rs
+++ b/src/variant_list_delete.rs
@@ -67,9 +67,6 @@ fn delete_list_element(variant_list: Variant, index: usize) -> Result<(Vec<u8>,
 }
 
 impl ScalarUDFImpl for VariantListDelete {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_delete"
diff --git a/src/variant_list_insert.rs b/src/variant_list_insert.rs
index 8ceb8e1..ef7ddca 100644
--- a/src/variant_list_insert.rs
+++ b/src/variant_list_insert.rs
@@ -29,9 +29,6 @@ impl Default for VariantListInsert {
 }
 
 impl ScalarUDFImpl for VariantListInsert {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_insert"
diff --git a/src/variant_normalize.rs b/src/variant_normalize.rs
index 4a92b20..90cda28 100644
--- a/src/variant_normalize.rs
+++ b/src/variant_normalize.rs
@@ -62,9 +62,6 @@ impl Default for VariantNormalizeUdf {
 }
 
 impl ScalarUDFImpl for VariantNormalizeUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_normalize"
diff --git a/src/variant_object_construct.rs b/src/variant_object_construct.rs
index 39dca94..fdb407b 100644
--- a/src/variant_object_construct.rs
+++ b/src/variant_object_construct.rs
@@ -29,9 +29,6 @@ impl Default for VariantObjectConstruct {
 }
 
 impl ScalarUDFImpl for VariantObjectConstruct {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_construct"
diff --git a/src/variant_object_delete.rs b/src/variant_object_delete.rs
index 9d21bda..14dd5f2 100644
--- a/src/variant_object_delete.rs
+++ b/src/variant_object_delete.rs
@@ -29,9 +29,6 @@ impl Default for VariantObjectDelete {
 }
 
 impl ScalarUDFImpl for VariantObjectDelete {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_delete"
diff --git a/src/variant_object_insert.rs b/src/variant_object_insert.rs
index ad5580e..39de766 100644
--- a/src/variant_object_insert.rs
+++ b/src/variant_object_insert.rs
@@ -29,9 +29,6 @@ impl Default for VariantObjectInsert {
 }
 
 impl ScalarUDFImpl for VariantObjectInsert {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_insert"
diff --git a/src/variant_object_keys.rs b/src/variant_object_keys.rs
index a7bfaea..ee231e4 100644
--- a/src/variant_object_keys.rs
+++ b/src/variant_object_keys.rs
@@ -45,9 +45,6 @@ fn append_keys_from_variant(v_opt: Option<Variant>, builder: &mut ListBuilder<St
 }
 
 impl ScalarUDFImpl for VariantObjectKeys {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_keys"
diff --git a/src/variant_pretty.rs b/src/variant_pretty.rs
index 33e3783..542cded 100644
--- a/src/variant_pretty.rs
+++ b/src/variant_pretty.rs
@@ -28,9 +28,6 @@ impl Default for VariantPretty {
 }
 
 impl ScalarUDFImpl for VariantPretty {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_pretty"
diff --git a/src/variant_to_json.rs b/src/variant_to_json.rs
index 271c0b0..8f54479 100644
--- a/src/variant_to_json.rs
+++ b/src/variant_to_json.rs
@@ -39,9 +39,6 @@ impl Default for VariantToJsonUdf {
 }
 
 impl ScalarUDFImpl for VariantToJsonUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_to_json"