Skip to content

Commit 33c14cc

Browse files
Bump deltalake and delta_kernel to latest
1 parent 14b79b7 commit 33c14cc

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

Cargo.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,8 @@ clap = { version = "4.5.42", default-features = false }
3535
config = { version = "0.14", default-features = false }
3636
const-oid = { version = "0.9.6", default-features = false }
3737
constant_time_eq = { version = "0.4.2" }
38-
delta_kernel = { version = "0.13.0", default-features = false, features = ["arrow-conversion"] }
39-
deltalake = { version = "0.27.0", default-features = false, features = ["rustls", "datafusion", "s3"] }
38+
delta_kernel = { version = "0.14.0", default-features = false, features = ["arrow-conversion"] }
39+
deltalake = { version = "0.28.0", default-features = false, features = ["rustls", "datafusion", "s3"] }
4040
fail = { version = "0.5.1", default-features = false }
4141
futures = { version = "0.3.31", default-features = false }
4242
gcp-bigquery-client = { git = "https://github.com/lquerel/gcp-bigquery-client.git", default-features = false, rev = "391a162642bd0af6d55e2310ef46adf96f21228c" }

etl-destinations/src/delta/client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ impl DeltaLakeClient {
266266
// todo(abhi): Return list of missing columns that need to be added
267267
// todo(abhi): Validate that existing columns are compatible
268268

269-
let _current_schema = table.schema();
269+
let _current_schema = table.snapshot()?.schema();
270270
let _expected_delta_schema = postgres_to_delta_schema(expected_schema)?;
271271

272272
// todo(abhi): Compare schemas and find missing columns

0 commit comments

Comments
 (0)