Run formatter

src/common/arrow-ffi/src/lib.rs

@@ -1,7 +1,6 @@
 use std::io::Cursor;
 
 use arrow2::{array::Array, datatypes::Field, ffi};
-
 #[cfg(feature = "python")]
 use pyo3::ffi::Py_uintptr_t;
 #[cfg(feature = "python")]

src/common/daft-config/src/lib.rs

@@ -105,15 +105,13 @@ impl DaftExecutionConfig {
 #[cfg(feature = "python")]
 mod python;
 
+#[cfg(feature = "python")]
+use pyo3::prelude::*;
 #[cfg(feature = "python")]
 pub use python::PyDaftExecutionConfig;
-
 #[cfg(feature = "python")]
 pub use python::PyDaftPlanningConfig;
 
-#[cfg(feature = "python")]
-use pyo3::prelude::*;
-
 #[cfg(feature = "python")]
 pub fn register_modules(parent: &Bound<PyModule>) -> PyResult<()> {
     parent.add_class::<python::PyDaftExecutionConfig>()?;

src/common/daft-config/src/python.rs

@@ -1,11 +1,11 @@
 use std::sync::Arc;
 
+use common_io_config::python::IOConfig as PyIOConfig;
 use common_py_serde::impl_bincode_py_state_serialization;
 use pyo3::prelude::*;
 use serde::{Deserialize, Serialize};
 
 use crate::{DaftExecutionConfig, DaftPlanningConfig};
-use common_io_config::python::IOConfig as PyIOConfig;
 
 #[derive(Clone, Default, Serialize, Deserialize)]
 #[pyclass(module = "daft.daft")]

src/common/display/src/mermaid.rs

@@ -1,6 +1,7 @@
-use indexmap::IndexMap;
 use std::fmt;
 
+use indexmap::IndexMap;
+
 use crate::{tree::TreeDisplay, DisplayLevel};
 
 pub trait MermaidDisplay: TreeDisplay {

src/common/error/src/lib.rs

@@ -1,5 +1,4 @@
 mod error;
-pub use error::DaftError;
-pub use error::DaftResult;
+pub use error::{DaftError, DaftResult};
 #[cfg(feature = "python")]
 mod python;

src/common/error/src/python.rs

@@ -1,5 +1,4 @@
-use pyo3::exceptions::PyFileNotFoundError;
-use pyo3::import_exception;
+use pyo3::{exceptions::PyFileNotFoundError, import_exception};
 
 use crate::DaftError;
 

src/common/file-formats/src/file_format.rs

@@ -8,7 +8,6 @@ use common_error::{DaftError, DaftResult};
 use common_py_serde::impl_bincode_py_state_serialization;
 #[cfg(feature = "python")]
 use pyo3::prelude::*;
-
 use serde::{Deserialize, Serialize};
 
 /// Format of a file, e.g. Parquet, CSV, JSON.

src/common/file-formats/src/file_format_config.rs

@@ -1,18 +1,17 @@
-use crate::FileFormat;
-use daft_schema::{field::Field, time_unit::TimeUnit};
-use serde::{Deserialize, Serialize};
-use std::hash::Hash;
-use std::{collections::BTreeMap, sync::Arc};
+use std::{collections::BTreeMap, hash::Hash, sync::Arc};
 
 use common_py_serde::impl_bincode_py_state_serialization;
-
+use daft_schema::{field::Field, time_unit::TimeUnit};
+use serde::{Deserialize, Serialize};
 #[cfg(feature = "python")]
 use {
     common_py_serde::{deserialize_py_object, serialize_py_object},
     daft_schema::python::{datatype::PyTimeUnit, field::PyField},
     pyo3::{pyclass, pymethods, types::PyAnyMethods, PyObject, PyResult, Python},
 };
 
+use crate::FileFormat;
+
 /// Configuration for parsing a particular file format.
 #[derive(Clone, Debug, PartialEq, Eq, Hash, Serialize, Deserialize)]
 pub enum FileFormatConfig {

src/common/file-formats/src/lib.rs

@@ -2,13 +2,12 @@ mod file_format;
 pub use file_format::FileFormat;
 
 mod file_format_config;
+#[cfg(feature = "python")]
+pub use file_format_config::DatabaseSourceConfig;
 pub use file_format_config::{
     CsvSourceConfig, FileFormatConfig, JsonSourceConfig, ParquetSourceConfig,
 };
 
-#[cfg(feature = "python")]
-pub use file_format_config::DatabaseSourceConfig;
-
 #[cfg(feature = "python")]
 pub mod python;
 

src/common/io-config/src/azure.rs

@@ -1,8 +1,6 @@
-use std::fmt::Display;
-use std::fmt::Formatter;
+use std::fmt::{Display, Formatter};
 
-use serde::Deserialize;
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 
 use crate::ObfuscatedString;
 

src/common/io-config/src/config.rs

@@ -1,11 +1,8 @@
-use std::fmt::Display;
-use std::fmt::Formatter;
+use std::fmt::{Display, Formatter};
 
-use serde::Deserialize;
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 
-use crate::HTTPConfig;
-use crate::{AzureConfig, GCSConfig, S3Config};
+use crate::{AzureConfig, GCSConfig, HTTPConfig, S3Config};
 #[derive(Clone, Default, Debug, Serialize, Deserialize, PartialEq, Eq, Hash)]
 pub struct IOConfig {
     pub s3: S3Config,

src/common/io-config/src/gcs.rs

@@ -1,8 +1,6 @@
-use std::fmt::Display;
-use std::fmt::Formatter;
+use std::fmt::{Display, Formatter};
 
-use serde::Deserialize;
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 
 use crate::ObfuscatedString;
 

src/common/io-config/src/http.rs

@@ -1,8 +1,6 @@
-use std::fmt::Display;
-use std::fmt::Formatter;
+use std::fmt::{Display, Formatter};
 
-use serde::Deserialize;
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 
 use crate::ObfuscatedString;
 

src/common/io-config/src/lib.rs

@@ -16,8 +16,11 @@ use secrecy::{ExposeSecret, Secret};
 use serde::{Deserialize, Deserializer, Serialize};
 
 pub use crate::{
-    azure::AzureConfig, config::IOConfig, gcs::GCSConfig, http::HTTPConfig, s3::S3Config,
-    s3::S3Credentials,
+    azure::AzureConfig,
+    config::IOConfig,
+    gcs::GCSConfig,
+    http::HTTPConfig,
+    s3::{S3Config, S3Credentials},
 };
 
 #[derive(Clone)]

src/common/io-config/src/python.rs

@@ -239,8 +239,7 @@ impl IOConfig {
     }
 
     pub fn __hash__(&self) -> PyResult<u64> {
-        use std::collections::hash_map::DefaultHasher;
-        use std::hash::Hash;
+        use std::{collections::hash_map::DefaultHasher, hash::Hash};
 
         let mut hasher = DefaultHasher::new();
         self.config.hash(&mut hasher);

src/common/io-config/src/s3.rs

@@ -1,15 +1,13 @@
+use std::{
+    any::Any,
+    fmt::{Debug, Display, Formatter},
+    hash::{Hash, Hasher},
+    time::SystemTime,
+};
+
 use aws_credential_types::provider::ProvideCredentials;
-use chrono::offset::Utc;
-use chrono::DateTime;
-use serde::Deserialize;
-use serde::Serialize;
-use std::any::Any;
-use std::fmt::Debug;
-use std::fmt::Display;
-use std::fmt::Formatter;
-use std::hash::Hash;
-use std::hash::Hasher;
-use std::time::SystemTime;
+use chrono::{offset::Utc, DateTime};
+use serde::{Deserialize, Serialize};
 
 pub use crate::ObfuscatedString;
 

src/common/py-serde/src/lib.rs

@@ -1,6 +1,6 @@
 mod python;
 
+pub use bincode;
+
 #[cfg(feature = "python")]
 pub use crate::{python::deserialize_py_object, python::serialize_py_object};
-
-pub use bincode;

src/common/py-serde/src/python.rs

@@ -1,8 +1,12 @@
+use std::fmt;
+
 #[cfg(feature = "python")]
 use pyo3::{types::PyAnyMethods, PyObject, Python};
-
-use serde::{de::Error as DeError, de::Visitor, ser::Error as SerError, Deserializer, Serializer};
-use std::fmt;
+use serde::{
+    de::{Error as DeError, Visitor},
+    ser::Error as SerError,
+    Deserializer, Serializer,
+};
 #[cfg(feature = "python")]
 
 pub fn serialize_py_object<S>(obj: &PyObject, s: S) -> Result<S::Ok, S::Error>

src/common/resource-request/src/lib.rs

@@ -1,3 +1,8 @@
+use std::{
+    hash::{Hash, Hasher},
+    ops::Add,
+};
+
 use common_hashable_float_wrapper::FloatWrapper;
 use common_py_serde::impl_bincode_py_state_serialization;
 #[cfg(feature = "python")]
@@ -8,10 +13,6 @@ use pyo3::{
     types::{PyModule, PyModuleMethods},
     Bound, PyObject, PyResult, Python,
 };
-
-use std::hash::{Hash, Hasher};
-use std::ops::Add;
-
 use serde::{Deserialize, Serialize};
 
 /// Resource request for a query fragment task.

src/common/treenode/src/lib.rs

@@ -939,9 +939,8 @@ impl<T: ConcreteTreeNode> TreeNode for T {
 mod tests {
     use std::fmt::Display;
 
-    use crate::Result;
     use crate::{
-        Transformed, TreeNode, TreeNodeIterator, TreeNodeRecursion, TreeNodeRewriter,
+        Result, Transformed, TreeNode, TreeNodeIterator, TreeNodeRecursion, TreeNodeRewriter,
         TreeNodeVisitor,
     };
 

src/daft-compression/src/compression.rs

@@ -1,8 +1,9 @@
+use std::{path::PathBuf, pin::Pin};
+
 use async_compression::tokio::bufread::{
     BrotliDecoder, BzDecoder, DeflateDecoder, GzipDecoder, LzmaDecoder, XzDecoder, ZlibDecoder,
     ZstdDecoder,
 };
-use std::{path::PathBuf, pin::Pin};
 use tokio::io::{AsyncBufRead, AsyncRead};
 use url::Url;
 

src/daft-core/src/array/boolean.rs

@@ -1,6 +1,5 @@
-use crate::datatypes::BooleanArray;
-
 use super::ops::as_arrow::AsArrow;
+use crate::datatypes::BooleanArray;
 
 impl BooleanArray {
     pub fn as_bitmap(&self) -> &arrow2::bitmap::Bitmap {

src/daft-core/src/array/fixed_size_list_array.rs

@@ -2,10 +2,11 @@ use std::sync::Arc;
 
 use common_error::{DaftError, DaftResult};
 
-use crate::array::growable::{Growable, GrowableArray};
-use crate::datatypes::DataType;
-use crate::datatypes::{DaftArrayType, Field};
-use crate::series::Series;
+use crate::{
+    array::growable::{Growable, GrowableArray},
+    datatypes::{DaftArrayType, DataType, Field},
+    series::Series,
+};
 
 #[derive(Clone, Debug)]
 pub struct FixedSizeListArray {
@@ -222,13 +223,12 @@ impl Iterator for FixedSizeListArrayIter<'_> {
 mod tests {
     use common_error::DaftResult;
 
+    use super::FixedSizeListArray;
     use crate::{
         datatypes::{DataType, Field, Int32Array},
         series::IntoSeries,
     };
 
-    use super::FixedSizeListArray;
-
     /// Helper that returns a FixedSizeListArray, with each list element at len=3
     fn get_i32_fixed_size_list_array(validity: &[bool]) -> FixedSizeListArray {
         let field = Field::new("foo", DataType::FixedSizeList(Box::new(DataType::Int32), 3));

src/daft-core/src/array/from.rs

@@ -1,14 +1,15 @@
-use std::borrow::Cow;
-use std::sync::Arc;
+use std::{borrow::Cow, sync::Arc};
 
-use crate::datatypes::{
-    BinaryArray, BooleanArray, DaftNumericType, DaftPhysicalType, DataType, Field,
-    FixedSizeBinaryArray, NullArray, Utf8Array, Utf8Type,
-};
-
-use crate::array::DataArray;
 use common_error::{DaftError, DaftResult};
 
+use crate::{
+    array::DataArray,
+    datatypes::{
+        BinaryArray, BooleanArray, DaftNumericType, DaftPhysicalType, DataType, Field,
+        FixedSizeBinaryArray, NullArray, Utf8Array, Utf8Type,
+    },
+};
+
 impl<T: DaftNumericType> From<(&str, Box<arrow2::array::PrimitiveArray<T::Native>>)>
     for DataArray<T>
 {

src/daft-core/src/array/from_iter.rs

@@ -1,7 +1,5 @@
-use crate::array::prelude::*;
-use crate::datatypes::prelude::*;
-
 use super::DataArray;
+use crate::{array::prelude::*, datatypes::prelude::*};
 
 impl<T> DataArray<T>
 where

src/daft-core/src/array/growable/arrow_growable.rs

@@ -2,9 +2,12 @@ use std::{marker::PhantomData, sync::Arc};
 
 use common_error::DaftResult;
 
-use crate::{array::prelude::*, datatypes::prelude::*, series::IntoSeries, series::Series};
-
 use super::Growable;
+use crate::{
+    array::prelude::*,
+    datatypes::prelude::*,
+    series::{IntoSeries, Series},
+};
 
 pub struct ArrowBackedDataArrayGrowable<
     'a,

src/daft-core/src/array/growable/fixed_size_list_growable.rs

@@ -1,15 +1,12 @@
 use common_error::DaftResult;
 
+use super::{bitmap_growable::ArrowBitmapGrowable, Growable};
 use crate::{
     array::{growable::make_growable, FixedSizeListArray},
-    datatypes::DataType,
-    datatypes::Field,
-    series::IntoSeries,
-    series::Series,
+    datatypes::{DataType, Field},
+    series::{IntoSeries, Series},
 };
 
-use super::{bitmap_growable::ArrowBitmapGrowable, Growable};
-
 pub struct FixedSizeListGrowable<'a> {
     name: String,
     dtype: DataType,

src/daft-core/src/array/growable/list_growable.rs

@@ -1,15 +1,13 @@
 use arrow2::types::Index;
 use common_error::DaftResult;
 
+use super::{bitmap_growable::ArrowBitmapGrowable, Growable};
 use crate::{
     array::{growable::make_growable, ListArray},
     datatypes::{DataType, Field},
-    series::IntoSeries,
-    series::Series,
+    series::{IntoSeries, Series},
 };
 
-use super::{bitmap_growable::ArrowBitmapGrowable, Growable};
-
 pub struct ListGrowable<'a> {
     name: String,
     dtype: DataType,