build: Update Rust toolchain to nightly-2024-07-26

crates/polars-arrow/src/array/dictionary/typed_iterator.rs

@@ -37,13 +37,12 @@ impl<O: Offset> DictValue for Utf8Array<O> {
             .ok_or_else(
                 || polars_err!(InvalidOperation: "could not convert array to dictionary value"),
             )
-            .map(|arr| {
+            .inspect(|arr| {
                 assert_eq!(
                     arr.null_count(),
                     0,
                     "null values in values not supported in iteration"
-                );
-                arr
+                )
             })
     }
 }
@@ -65,13 +64,12 @@ impl DictValue for Utf8ViewArray {
             .ok_or_else(
                 || polars_err!(InvalidOperation: "could not convert array to dictionary value"),
             )
-            .map(|arr| {
+            .inspect(|arr| {
                 assert_eq!(
                     arr.null_count(),
                     0,
                     "null values in values not supported in iteration"
-                );
-                arr
+                )
             })
     }
 }

crates/polars-arrow/src/scalar/fixed_size_list.rs

@@ -31,10 +31,9 @@ impl FixedSizeListScalar {
     pub fn new(data_type: ArrowDataType, values: Option<Box<dyn Array>>) -> Self {
         let (field, size) = FixedSizeListArray::get_child_and_size(&data_type);
         let inner_data_type = field.data_type();
-        let values = values.map(|x| {
+        let values = values.inspect(|x| {
             assert_eq!(inner_data_type, x.data_type());
             assert_eq!(size, x.len());
-            x
         });
         Self { values, data_type }
     }

crates/polars-core/src/frame/row/av_buffer.rs

@@ -125,8 +125,8 @@ impl<'a> AnyValueBuffer<'a> {
 
             // dynamic types
             (String(builder), av) => match av {
-                AnyValue::Int64(v) => builder.append_value(&format!("{v}")),
-                AnyValue::Float64(v) => builder.append_value(&format!("{v}")),
+                AnyValue::Int64(v) => builder.append_value(format!("{v}")),
+                AnyValue::Float64(v) => builder.append_value(format!("{v}")),
                 AnyValue::Boolean(true) => builder.append_value("true"),
                 AnyValue::Boolean(false) => builder.append_value("false"),
                 _ => return None,

crates/polars-expr/src/expressions/binary.rs

@@ -435,13 +435,12 @@ mod stats {
                 // Default: read the file
                 _ => Ok(true),
             };
-            out.map(|read| {
-                if state.verbose() && read {
+            out.inspect(|read| {
+                if state.verbose() && *read {
                     eprintln!("parquet file must be read, statistics not sufficient for predicate.")
-                } else if state.verbose() && !read {
+                } else if state.verbose() && !*read {
                     eprintln!("parquet file can be skipped, the statistics were sufficient to apply the predicate.")
-                };
-                read
+                }
             })
         }
     }

crates/polars-io/src/pl_async.rs

@@ -37,14 +37,16 @@ impl<T: GetSize, E: Error> GetSize for Result<T, E> {
     }
 }
 
+#[cfg(feature = "cloud")]
 pub(crate) struct Size(u64);
 
+#[cfg(feature = "cloud")]
 impl GetSize for Size {
     fn size(&self) -> u64 {
         self.0
     }
 }
-
+#[cfg(feature = "cloud")]
 impl From<u64> for Size {
     fn from(value: u64) -> Self {
         Self(value)

crates/polars-json/src/json/write/mod.rs

@@ -144,15 +144,15 @@ where
     W: std::io::Write,
     I: FallibleStreamingIterator<Item = [u8], Error = PolarsError>,
 {
-    writer.write_all(&[b'['])?;
+    writer.write_all(b"[")?;
     let mut is_first_row = true;
     while let Some(block) = blocks.next()? {
         if !is_first_row {
-            writer.write_all(&[b','])?;
+            writer.write_all(b",")?;
         }
         is_first_row = false;
         writer.write_all(block)?;
     }
-    writer.write_all(&[b']'])?;
+    writer.write_all(b"]")?;
     Ok(())
 }

crates/polars-parquet/src/arrow/write/utils.rs

@@ -129,10 +129,7 @@ impl<T, I: Iterator<Item = T>> Iterator for ExactSizedIter<T, I> {
 
     #[inline]
     fn next(&mut self) -> Option<Self::Item> {
-        self.iter.next().map(|x| {
-            self.remaining -= 1;
-            x
-        })
+        self.iter.next().inspect(|_| self.remaining -= 1)
     }
 
     #[inline]

crates/polars-pipe/src/executors/sinks/io.rs

@@ -40,7 +40,7 @@ fn get_spill_dir(operation_name: &'static str) -> PolarsResult<PathBuf> {
     let id = uuid::Uuid::new_v4();
 
     let mut dir = std::path::PathBuf::from(get_base_temp_dir());
-    dir.push(&format!("polars/{operation_name}/{id}"));
+    dir.push(format!("polars/{operation_name}/{id}"));
 
     if !dir.exists() {
         fs::create_dir_all(&dir).map_err(|err| {
@@ -77,7 +77,7 @@ fn gc_thread(operation_name: &'static str, rx: Receiver<PathBuf>) {
     let _ = std::thread::spawn(move || {
         // First clean all existing
         let mut dir = std::path::PathBuf::from(get_base_temp_dir());
-        dir.push(&format!("polars/{operation_name}"));
+        dir.push(format!("polars/{operation_name}"));
 
         // if the directory does not exist, there is nothing to clean
         let rd = match std::fs::read_dir(&dir) {

crates/polars-pipe/src/executors/sources/csv.rs

@@ -57,10 +57,9 @@ impl CsvSource {
         let options = self.options.clone().unwrap();
         let mut with_columns = file_options.with_columns;
         let mut projected_len = 0;
-        with_columns.as_ref().map(|columns| {
-            projected_len = columns.len();
-            columns
-        });
+        with_columns
+            .as_ref()
+            .inspect(|columns| projected_len = columns.len());
 
         if projected_len == 0 {
             with_columns = None;

crates/polars-plan/src/client/check.rs

@@ -153,10 +153,9 @@ impl<'a> Iterator for DslPlanIter<'a> {
     type Item = &'a DslPlan;
 
     fn next(&mut self) -> Option<Self::Item> {
-        self.stack.pop().map(|next| {
-            next.inputs(&mut self.stack);
-            next
-        })
+        self.stack
+            .pop()
+            .inspect(|next| next.inputs(&mut self.stack))
     }
 }
 

crates/polars-plan/src/plans/iterator.rs

@@ -112,10 +112,9 @@ impl<'a> Iterator for ExprIter<'a> {
     type Item = &'a Expr;
 
     fn next(&mut self) -> Option<Self::Item> {
-        self.stack.pop().map(|current_expr| {
-            current_expr.nodes(&mut self.stack);
-            current_expr
-        })
+        self.stack
+            .pop()
+            .inspect(|current_expr| current_expr.nodes(&mut self.stack))
     }
 }
 

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "nightly-2024-06-23"
+channel = "nightly-2024-07-26"