Update delta-rs version

Signed-off-by: Abhi Agarwal <[email protected]>

Author: abhi-airspace-intelligence

Cargo.toml

@@ -44,7 +44,7 @@ config = { version = "0.14", default-features = false }
 const-oid = { version = "0.9.6", default-features = false }
 constant_time_eq = { version = "0.4.2" }
 dashmap = { version = "6.1.0", default-features = false }
-deltalake = { git = "https://github.com/delta-io/delta-rs.git", rev = "19f19db3b521c350f9b7056e45b6a2be8fa13f80", default-features = false }
+deltalake = { git = "https://github.com/delta-io/delta-rs.git", rev = "d30b11f673b0111dbb0f904bf89d5b917ea652ed", default-features = false }
 fail = { version = "0.5.1", default-features = false }
 futures = { version = "0.3.31", default-features = false }
 gcp-bigquery-client = { version = "0.27.0", default-features = false }

etl-destinations/src/deltalake/schema.rs

@@ -8,7 +8,7 @@ use deltalake::arrow::array::{
     TimestampMicrosecondArray, UInt32Array, new_empty_array,
 };
 use deltalake::arrow::datatypes::{
-    DataType as ArrowDataType, Field as ArrowField, Schema as ArrowSchema, TimeUnit,
+    DataType as ArrowDataType, DecimalType, Field as ArrowField, Schema as ArrowSchema, TimeUnit,
 };
 use deltalake::arrow::error::ArrowError;
 use deltalake::arrow::record_batch::RecordBatch;
@@ -859,11 +859,10 @@ mod tests {
             postgres_type_to_delta(&PgType::BYTEA).unwrap(),
             DeltaDataType::BINARY
         ));
-        // TODO(abhi): https://github.com/delta-io/delta-rs/issues/3729
-        // assert!(matches!(
-        //     postgres_type_to_delta(&PgType::NUMERIC).unwrap(),
-        //     DeltaDataType::Primitive(PrimitiveType::Decimal(DecimalType { .. }))
-        // ));
+        assert!(matches!(
+            postgres_type_to_delta(&PgType::NUMERIC).unwrap(),
+            DeltaDataType::Primitive(PrimitiveType::Decimal(DecimalType { .. }))
+        ));
     }
 
     #[test]