auto fix

Eventual-Inc · Oct 1, 2024 · 7f15901 · 7f15901
1 parent 44f3fdc
commit 7f15901
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 15 deletions.
diff --git a/src/common/file-formats/src/file_format_config.rs b/src/common/file-formats/src/file_format_config.rs
@@ -33,13 +33,13 @@ impl FileFormatConfig {
     #[must_use]
     pub fn var_name(&self) -> &'static str {
         match self {
-            FileFormatConfig::Parquet(_) => "Parquet",
-            FileFormatConfig::Csv(_) => "Csv",
-            FileFormatConfig::Json(_) => "Json",
+            Self::Parquet(_) => "Parquet",
+            Self::Csv(_) => "Csv",
+            Self::Json(_) => "Json",
             #[cfg(feature = "python")]
-            FileFormatConfig::Database(_) => "Database",
+            Self::Database(_) => "Database",
             #[cfg(feature = "python")]
-            FileFormatConfig::PythonFunction => "PythonFunction",
+            Self::PythonFunction => "PythonFunction",
         }
     }
 

diff --git a/src/daft-core/src/array/growable/fixed_size_list_growable.rs b/src/daft-core/src/array/growable/fixed_size_list_growable.rs
@@ -63,7 +63,7 @@ impl<'a> Growable for FixedSizeListGrowable<'a> {
         );
 
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.extend(index, start, len)
+            growable_validity.extend(index, start, len);
         }
     }
 
@@ -72,7 +72,7 @@ impl<'a> Growable for FixedSizeListGrowable<'a> {
             .add_nulls(additional * self.element_fixed_len);
 
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.add_nulls(additional)
+            growable_validity.add_nulls(additional);
         }
     }
 

diff --git a/src/daft-core/src/array/growable/list_growable.rs b/src/daft-core/src/array/growable/list_growable.rs
@@ -72,7 +72,7 @@ impl<'a> Growable for ListGrowable<'a> {
         );
 
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.extend(index, start, len)
+            growable_validity.extend(index, start, len);
         }
 
         self.growable_offsets
@@ -82,7 +82,7 @@ impl<'a> Growable for ListGrowable<'a> {
 
     fn add_nulls(&mut self, additional: usize) {
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.add_nulls(additional)
+            growable_validity.add_nulls(additional);
         }
         self.growable_offsets.extend_constant(additional);
     }

diff --git a/src/daft-core/src/array/growable/struct_growable.rs b/src/daft-core/src/array/growable/struct_growable.rs
@@ -68,7 +68,7 @@ impl<'a> Growable for StructGrowable<'a> {
         }
 
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.extend(index, start, len)
+            growable_validity.extend(index, start, len);
         }
     }
 
@@ -78,7 +78,7 @@ impl<'a> Growable for StructGrowable<'a> {
         }
 
         if let Some(growable_validity) = &mut self.growable_validity {
-            growable_validity.add_nulls(additional)
+            growable_validity.add_nulls(additional);
         }
     }
 

diff --git a/src/daft-scheduler/src/adaptive.rs b/src/daft-scheduler/src/adaptive.rs
@@ -71,10 +71,7 @@ impl AdaptivePhysicalPlanScheduler {
                 None, // TODO(sammy) thread through clustering spec to Python
             );
 
-            self.planner.update(MaterializedResults {
-                in_memory_info,
-                source_id,
-            })?;
+            self.planner.update(MaterializedResults { source_id, in_memory_info })?;
             Ok(())
         })
     }