From be85f80f835c7a81572e66e2e3d223fa0615f369 Mon Sep 17 00:00:00 2001
From: Ion Koutsouris <15728914+ion-elgreco@users.noreply.github.com>
Date: Sun, 24 Nov 2024 14:11:06 +0100
Subject: [PATCH] chore: fmt

---
 crates/core/src/delta_datafusion/mod.rs | 22 +++++++++++++---------
 1 file changed, 13 insertions(+), 9 deletions(-)

diff --git a/crates/core/src/delta_datafusion/mod.rs b/crates/core/src/delta_datafusion/mod.rs
index 3eb725aee0..eb0fdd6867 100644
--- a/crates/core/src/delta_datafusion/mod.rs
+++ b/crates/core/src/delta_datafusion/mod.rs
@@ -1206,13 +1206,17 @@ impl DeltaDataChecker {
     pub fn new(snapshot: &DeltaTableState) -> Self {
         let invariants = snapshot.schema().get_invariants().unwrap_or_default();
         let constraints = snapshot.table_config().get_constraints();
-        let non_nullable_columns = snapshot.schema().fields().filter_map(|f|{
-            if !f.is_nullable() {
-                Some(f.name().clone())
-            } else {
-                None
-            }
-        }).collect_vec();
+        let non_nullable_columns = snapshot
+            .schema()
+            .fields()
+            .filter_map(|f| {
+                if !f.is_nullable() {
+                    Some(f.name().clone())
+                } else {
+                    None
+                }
+            })
+            .collect_vec();
         Self {
             invariants,
             constraints,
@@ -1226,7 +1230,7 @@ impl DeltaDataChecker {
     /// If it does not, it will return [DeltaTableError::InvalidData] with a list
     /// of values that violated each invariant.
     pub async fn check_batch(&self, record_batch: &RecordBatch) -> Result<(), DeltaTableError> {
-        let _ = self.check_nullability(record_batch, &self.non_nullable_columns)?;
+        self.check_nullability(record_batch, &self.non_nullable_columns)?;
         self.enforce_checks(record_batch, &self.invariants).await?;
         self.enforce_checks(record_batch, &self.constraints).await
     }
@@ -1235,7 +1239,7 @@ impl DeltaDataChecker {
         &self,
         record_batch: &RecordBatch,
         non_nullable_columns: &Vec<String>,
-    )  -> Result<(), DeltaTableError> {
+    ) -> Result<(), DeltaTableError> {
         let mut violations = Vec::new();
         for col in non_nullable_columns {
             if let Some(arr) = record_batch.column_by_name(col) {