c

pola-rs · Mar 5, 2025 · 916638f · 916638f
1 parent 3cb7e64
commit 916638f
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/crates/polars-io/src/cloud/adaptors.rs b/crates/polars-io/src/cloud/adaptors.rs
@@ -41,7 +41,7 @@ impl WriterState {
                     self.try_with_writer(func)
                 },
             },
-            Self::Err(e) => Err(std::io::Error::new(e.kind(), e.to_string())),
+            Self::Err(e) => Err(clone_io_err(e)),
         }
     }
 }
@@ -149,7 +149,7 @@ impl tokio::io::AsyncWrite for CloudWriter {
                 },
                 v => v,
             },
-            WriterState::Err(e) => Poll::Ready(Err(std::io::Error::new(e.kind(), e.to_string()))),
+            WriterState::Err(e) => Poll::Ready(Err(clone_io_err(e))),
         }
     }
 
@@ -165,7 +165,7 @@ impl tokio::io::AsyncWrite for CloudWriter {
                 },
                 v => v,
             },
-            WriterState::Err(e) => Poll::Ready(Err(std::io::Error::new(e.kind(), e.to_string()))),
+            WriterState::Err(e) => Poll::Ready(Err(clone_io_err(e))),
         }
     }
 
@@ -181,7 +181,7 @@ impl tokio::io::AsyncWrite for CloudWriter {
                 },
                 v => v,
             },
-            WriterState::Err(e) => Poll::Ready(Err(std::io::Error::new(e.kind(), e.to_string()))),
+            WriterState::Err(e) => Poll::Ready(Err(clone_io_err(e))),
         }
     }
 }
@@ -197,6 +197,10 @@ impl Drop for CloudWriter {
     }
 }
 
+fn clone_io_err(e: &std::io::Error) -> std::io::Error {
+    std::io::Error::new(e.kind(), e.to_string())
+}
+
 #[cfg(feature = "csv")]
 #[cfg(test)]
 mod tests {