chore: upgrade to the latest released 0.25

Closes #212

Signed-off-by: R. Tyler Croy <[email protected]>

Author: rtyler

Cargo.toml

@@ -35,12 +35,9 @@ uuid = { version = "0.8", features = ["serde", "v4"] }
 url = "2.3"
 
 # datafusion feature is required for writer version 2
-#deltalake-core = { version = "0.23.0", features = ["json", "datafusion"]}
-#deltalake-aws = { version = "0.6.0", optional = true }
-#deltalake-azure = { version = "0.6.0", optional = true }
-deltalake-core = { git = "https://github.com/buoyant-data/delta-rs", branch = "default-engine-rustls", features = ["json", "datafusion"] }
-deltalake-aws = { git = "https://github.com/buoyant-data/delta-rs", branch = "default-engine-rustls", optional = true }
-deltalake-azure= { git = "https://github.com/buoyant-data/delta-rs", branch = "default-engine-rustls", optional = true }
+deltalake-core = { version = "0.25.0", features = ["json", "datafusion"]}
+deltalake-aws = { version = "0.8.0", optional = true }
+deltalake-azure = { version = "0.8.0", optional = true }
 
 # s3 feature enabled, helps for locking interactions with DLQ
 dynamodb_lock = { version = "0.6.0", optional = true }

src/lib.rs

@@ -979,8 +979,7 @@ impl IngestProcessor {
                         epoch_id,
                     },
                 )
-                .await
-                .map_err(DeltaTableError::from);
+                .await;
             match commit {
                 Ok(v) => {
                     /*if v != version {

src/offsets.rs

@@ -75,7 +75,7 @@ pub(crate) async fn write_offsets_to_delta(
         } else {
             let partitions = conflict_offsets
                 .iter()
-                .map(|p| p.0.split('-').last().unwrap_or("N/A"))
+                .map(|p| p.0.split('-').next_back().unwrap_or("N/A"))
                 .collect::<Vec<&str>>()
                 .join(",");
 
@@ -127,8 +127,7 @@ async fn commit_partition_offsets(
                 epoch_id,
             },
         )
-        .await
-        .map_err(DeltaTableError::from);
+        .await;
     match commit {
         Ok(v) => {
             info!(

src/writer.rs

@@ -594,8 +594,7 @@ impl DataWriter {
                     predicate: None,
                 },
             )
-            .await
-            .map_err(DeltaTableError::from)?;
+            .await?;
         Ok(commit.version)
     }
 }