fmt

Eventual-Inc · Sep 25, 2024 · 90e377e · 90e377e
1 parent 33c6b87
commit 90e377e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 16 deletions.
diff --git a/src/daft-core/src/array/ops/concat_agg.rs b/src/daft-core/src/array/ops/concat_agg.rs
@@ -208,10 +208,7 @@ impl DaftConcatAggable for DataArray<Utf8Type> {
             )))
         };
 
-        Ok(Self::from((
-            self.field.name.as_ref(),
-            concat_per_group,
-        )))
+        Ok(Self::from((self.field.name.as_ref(), concat_per_group)))
     }
 }
 

diff --git a/src/daft-sql/src/modules/partitioning.rs b/src/daft-sql/src/modules/partitioning.rs
@@ -32,18 +32,10 @@ impl SQLFunction for PartitioningExpr {
         planner: &crate::planner::SQLPlanner,
     ) -> crate::error::SQLPlannerResult<daft_dsl::ExprRef> {
         match self {
-            Self::Years => {
-                partitioning_helper(args, planner, "years", partitioning::years)
-            }
-            Self::Months => {
-                partitioning_helper(args, planner, "months", partitioning::months)
-            }
-            Self::Days => {
-                partitioning_helper(args, planner, "days", partitioning::days)
-            }
-            Self::Hours => {
-                partitioning_helper(args, planner, "hours", partitioning::hours)
-            }
+            Self::Years => partitioning_helper(args, planner, "years", partitioning::years),
+            Self::Months => partitioning_helper(args, planner, "months", partitioning::months),
+            Self::Days => partitioning_helper(args, planner, "days", partitioning::days),
+            Self::Hours => partitioning_helper(args, planner, "hours", partitioning::hours),
             Self::IcebergBucket(_) => {
                 ensure!(args.len() == 2, "iceberg_bucket takes exactly 2 arguments");
                 let input = planner.plan_function_arg(&args[0])?;