Skip to content

Commit 3215340

Browse files
committed
chore: finish datafusion 49 upgrade
Signed-off-by: R. Tyler Croy <rtyler@brokenco.de>
1 parent f7df763 commit 3215340

File tree

2 files changed

+2
-8
lines changed

2 files changed

+2
-8
lines changed

Cargo.toml

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -95,10 +95,3 @@ Arro3 = "Arro3"
9595
AKS = "AKS"
9696
# to avoid using 'type' as a field name.
9797
tpe = "tpe"
98-
99-
# temp patch to https://github.com/apache/datafusion/pull/16822
100-
# before merge to branch-49
101-
[patch.crates-io]
102-
datafusion = { git = "https://github.com/apache/datafusion.git", rev = "fb02f4ec1d17f268ca7be9757fac121213c9bdc9" }
103-
datafusion-ffi = { git = "https://github.com/apache/datafusion.git", rev = "fb02f4ec1d17f268ca7be9757fac121213c9bdc9" }
104-
datafusion-proto = { git = "https://github.com/apache/datafusion.git", rev = "fb02f4ec1d17f268ca7be9757fac121213c9bdc9" }

python/src/writer.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,8 @@ impl LazyBatchGenerator for ArrowStreamBatchGenerator {
7878
match stream_reader.next() {
7979
Some(Ok(record_batch)) => Ok(Some(record_batch)),
8080
Some(Err(err)) => Err(deltalake::datafusion::error::DataFusionError::ArrowError(
81-
err, None,
81+
Box::new(err),
82+
None,
8283
)),
8384
None => Ok(None), // End of stream
8485
}

0 commit comments

Comments
 (0)