[CHORE] auto-fix prefer Self over explicit type

Cargo.toml

@@ -224,6 +224,9 @@ version = "0.11.0"
 features = ["derive", "rc"]
 version = "1.0.200"
 
+[workspace.lints.clippy]
+use-self = "deny"
+
 [workspace.package]
 edition = "2021"
 version = "0.3.0-dev0"

src/common/arrow-ffi/Cargo.toml

@@ -5,6 +5,9 @@ pyo3 = {workspace = true, optional = true}
 [features]
 python = ["dep:pyo3"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-arrow-ffi"

src/common/daft-config/Cargo.toml

@@ -7,6 +7,9 @@ serde = {workspace = true}
 [features]
 python = ["dep:pyo3", "common-io-config/python"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-daft-config"

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

@@ -60,7 +60,7 @@ pub struct DaftExecutionConfig {
 
 impl Default for DaftExecutionConfig {
     fn default() -> Self {
-        DaftExecutionConfig {
+        Self {
             scan_tasks_min_size_bytes: 96 * 1024 * 1024,  // 96MB
             scan_tasks_max_size_bytes: 384 * 1024 * 1024, // 384MB
             broadcast_join_size_bytes_threshold: 10 * 1024 * 1024, // 10 MiB

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

@@ -17,27 +17,24 @@
 impl PyDaftPlanningConfig {
     #[new]
     pub fn new() -> Self {
-        PyDaftPlanningConfig::default()
+        Self::default()
     }
 
     #[staticmethod]
     pub fn from_env() -> Self {
-        PyDaftPlanningConfig {
+        Self {
             config: Arc::new(DaftPlanningConfig::from_env()),
         }
     }
 
-    fn with_config_values(
-        &mut self,
-        default_io_config: Option<PyIOConfig>,
-    ) -> PyResult<PyDaftPlanningConfig> {
+    fn with_config_values(&mut self, default_io_config: Option<PyIOConfig>) -> PyResult<Self> {
         let mut config = self.config.as_ref().clone();
 
         if let Some(default_io_config) = default_io_config {
             config.default_io_config = default_io_config.config;
         }
 
-        Ok(PyDaftPlanningConfig {
+        Ok(Self {
             config: Arc::new(config),
         })
     }
@@ -67,12 +64,12 @@
 impl PyDaftExecutionConfig {
     #[new]
     pub fn new() -> Self {
-        PyDaftExecutionConfig::default()
+        Self::default()
     }
 
     #[staticmethod]
     pub fn from_env() -> Self {
-        PyDaftExecutionConfig {
+        Self {
             config: Arc::new(DaftExecutionConfig::from_env()),
         }
     }
@@ -98,7 +95,7 @@
         enable_aqe: Option<bool>,
         enable_native_executor: Option<bool>,
         default_morsel_size: Option<usize>,
-    ) -> PyResult<PyDaftExecutionConfig> {
+    ) -> PyResult<Self> {
         let mut config = self.config.as_ref().clone();
 
         if let Some(scan_tasks_max_size_bytes) = scan_tasks_max_size_bytes {
@@ -161,7 +158,7 @@
             config.default_morsel_size = default_morsel_size;
         }
 
-        Ok(PyDaftExecutionConfig {
+        Ok(Self {
             config: Arc::new(config),
         })
     }

src/common/display/Cargo.toml

@@ -8,6 +8,9 @@ textwrap = {version = "0.16.1"}
 [features]
 python = ["dep:pyo3"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-display"

src/common/error/Cargo.toml

@@ -8,6 +8,9 @@ thiserror = {workspace = true}
 [features]
 python = ["dep:pyo3"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-error"

src/common/error/src/python.rs

@@ -10,7 +10,7 @@ import_exception!(daft.exceptions, ByteStreamError);
 import_exception!(daft.exceptions, SocketError);
 
 impl std::convert::From<DaftError> for pyo3::PyErr {
-    fn from(err: DaftError) -> pyo3::PyErr {
+    fn from(err: DaftError) -> Self {
         match err {
             DaftError::PyO3Error(pyerr) => pyerr,
             DaftError::FileNotFound { path, source } => {

src/common/file-formats/Cargo.toml

@@ -9,6 +9,9 @@ serde_json = {workspace = true, optional = true}
 [features]
 python = ["dep:pyo3", "dep:serde_json", "common-error/python", "common-py-serde/python", "daft-schema/python"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-file-formats"

src/common/hashable-float-wrapper/Cargo.toml

@@ -1,6 +1,9 @@
 [dependencies]
 serde = {workspace = true}
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-hashable-float-wrapper"

src/common/io-config/Cargo.toml

@@ -12,6 +12,9 @@ typetag = "0.2.16"
 [features]
 python = ["dep:pyo3", "common-error/python", "common-py-serde/python"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-io-config"

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

@@ -12,7 +12,7 @@
 
 impl Default for HTTPConfig {
     fn default() -> Self {
-        HTTPConfig {
+        Self {
             user_agent: "daft/0.0.1".to_string(), // NOTE: Ideally we grab the version of Daft, but that requires a dependency on daft-core
             bearer_token: None,
         }
@@ -21,7 +21,7 @@
 
 impl HTTPConfig {
     pub fn new<S: Into<ObfuscatedString>>(bearer_token: Option<S>) -> Self {
-        HTTPConfig {
+        Self {
             bearer_token: bearer_token.map(|t| t.into()),
             ..Default::default()
         }

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

@@ -73,12 +73,12 @@
         D: Deserializer<'de>,
     {
         let s = String::deserialize(deserializer)?;
-        Ok(ObfuscatedString(s.into()))
+        Ok(Self(s.into()))
     }
 }
 
 impl From<String> for ObfuscatedString {
     fn from(value: String) -> Self {
-        ObfuscatedString(value.into())
+        Self(value.into())
     }
 }

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

@@ -154,7 +154,7 @@
         gcs: Option<GCSConfig>,
         http: Option<HTTPConfig>,
     ) -> Self {
-        IOConfig {
+        Self {
             config: config::IOConfig {
                 s3: s3.unwrap_or_default().config,
                 azure: azure.unwrap_or_default().config,
@@ -171,7 +171,7 @@
         gcs: Option<GCSConfig>,
         http: Option<HTTPConfig>,
     ) -> Self {
-        IOConfig {
+        Self {
             config: config::IOConfig {
                 s3: s3.map(|s3| s3.config).unwrap_or(self.config.s3.clone()),
                 azure: azure
@@ -274,7 +274,7 @@
         profile_name: Option<String>,
     ) -> PyResult<Self> {
         let def = crate::S3Config::default();
-        Ok(S3Config {
+        Ok(Self {
             config: crate::S3Config {
                 region_name: region_name.or(def.region_name),
                 endpoint_url: endpoint_url.or(def.endpoint_url),
@@ -333,7 +333,7 @@
         force_virtual_addressing: Option<bool>,
         profile_name: Option<String>,
     ) -> PyResult<Self> {
-        Ok(S3Config {
+        Ok(Self {
             config: crate::S3Config {
                 region_name: region_name.or_else(|| self.config.region_name.clone()),
                 endpoint_url: endpoint_url.or_else(|| self.config.endpoint_url.clone()),
@@ -545,7 +545,7 @@
             })
             .transpose()?;
 
-        Ok(S3Credentials {
+        Ok(Self {
             credentials: crate::S3Credentials {
                 key_id,
                 access_key,
@@ -606,7 +606,7 @@
 impl PyS3CredentialsProvider {
     pub fn new(provider: Bound<PyAny>) -> PyResult<Self> {
         let hash = provider.hash()?;
-        Ok(PyS3CredentialsProvider {
+        Ok(Self {
             provider: provider.into(),
             hash,
         })
@@ -693,7 +693,7 @@
         use_ssl: Option<bool>,
     ) -> Self {
         let def = crate::AzureConfig::default();
-        AzureConfig {
+        Self {
             config: crate::AzureConfig {
                 storage_account: storage_account.or(def.storage_account),
                 access_key: access_key.map(|v| v.into()).or(def.access_key),
@@ -725,7 +725,7 @@
         endpoint_url: Option<String>,
         use_ssl: Option<bool>,
     ) -> Self {
-        AzureConfig {
+        Self {
             config: crate::AzureConfig {
                 storage_account: storage_account.or_else(|| self.config.storage_account.clone()),
                 access_key: access_key
@@ -835,7 +835,7 @@
         anonymous: Option<bool>,
     ) -> Self {
         let def = crate::GCSConfig::default();
-        GCSConfig {
+        Self {
             config: crate::GCSConfig {
                 project_id: project_id.or(def.project_id),
                 credentials: credentials.map(|v| v.into()).or(def.credentials),
@@ -852,7 +852,7 @@
         token: Option<String>,
         anonymous: Option<bool>,
     ) -> Self {
-        GCSConfig {
+        Self {
             config: crate::GCSConfig {
                 project_id: project_id.or_else(|| self.config.project_id.clone()),
                 credentials: credentials
@@ -907,7 +907,7 @@
 impl HTTPConfig {
     #[new]
     pub fn new(bearer_token: Option<String>) -> Self {
-        HTTPConfig {
+        Self {
             config: crate::HTTPConfig::new(bearer_token),
         }
     }

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

@@ -138,7 +138,7 @@ impl S3Config {
 
 impl Default for S3Config {
     fn default() -> Self {
-        S3Config {
+        Self {
             region_name: None,
             endpoint_url: None,
             key_id: None,

src/common/py-serde/Cargo.toml

@@ -6,6 +6,9 @@ serde = {workspace = true}
 [features]
 python = ["dep:pyo3"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-py-serde"

src/common/resource-request/Cargo.toml

@@ -7,6 +7,9 @@ serde = {workspace = true}
 [features]
 python = ["dep:pyo3", "common-py-serde/python"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-resource-request"

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

@@ -85,7 +85,7 @@
     ///
     /// Currently, this returns true unless one resource request has a non-zero CPU request and the other task has a
     /// non-zero GPU request.
-    pub fn is_pipeline_compatible_with(&self, other: &ResourceRequest) -> bool {
+    pub fn is_pipeline_compatible_with(&self, other: &Self) -> bool {
         let self_num_cpus = self.num_cpus;
         let self_num_gpus = self.num_gpus;
         let other_num_cpus = other.num_cpus;
@@ -100,7 +100,7 @@
         }
     }
 
-    pub fn max(&self, other: &ResourceRequest) -> Self {
+    pub fn max(&self, other: &Self) -> Self {
         let max_num_cpus = lift(float_max, self.num_cpus, other.num_cpus);
         let max_num_gpus = lift(float_max, self.num_gpus, other.num_gpus);
         let max_memory_bytes = lift(std::cmp::max, self.memory_bytes, other.memory_bytes);
@@ -152,8 +152,8 @@
     }
 }
 
-impl AsRef<ResourceRequest> for ResourceRequest {
-    fn as_ref(&self) -> &ResourceRequest {
+impl AsRef<Self> for ResourceRequest {
+    fn as_ref(&self) -> &Self {
         self
     }
 }
@@ -200,21 +200,21 @@
     }
 
     pub fn with_num_cpus(&self, num_cpus: Option<f64>) -> Self {
-        ResourceRequest {
+        Self {
             num_cpus,
             ..self.clone()
         }
     }
 
     pub fn with_num_gpus(&self, num_gpus: Option<f64>) -> Self {
-        ResourceRequest {
+        Self {
             num_gpus,
             ..self.clone()
         }
     }
 
     pub fn with_memory_bytes(&self, memory_bytes: Option<usize>) -> Self {
-        ResourceRequest {
+        Self {
             memory_bytes,
             ..self.clone()
         }

src/common/system-info/Cargo.toml

@@ -5,6 +5,9 @@ sysinfo = "0.30.7"
 [features]
 python = ["dep:pyo3"]
 
+[lints]
+workspace = true
+
 [package]
 edition = {workspace = true}
 name = "common-system-info"

src/common/system-info/src/lib.rs

@@ -9,7 +9,7 @@ pub struct SystemInfo {
 
 impl Default for SystemInfo {
     fn default() -> Self {
-        SystemInfo {
+        Self {
             info: sysinfo::System::new_with_specifics(
                 RefreshKind::new()
                     .with_cpu(CpuRefreshKind::everything())