Skip to content

Commit

Permalink
chore: clippy + fix deltalake-unity deps
Browse files Browse the repository at this point in the history
  • Loading branch information
ion-elgreco committed Jan 1, 2025
1 parent bc40d54 commit be76272
Show file tree
Hide file tree
Showing 6 changed files with 17 additions and 18 deletions.
3 changes: 2 additions & 1 deletion crates/aws/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ impl LogStoreFactory for S3LogStoreFactory {
store,
)?));
}
Ok(default_logstore(store, location, &options))
Ok(default_logstore(store, location, options))
}
}

Expand Down Expand Up @@ -141,6 +141,7 @@ impl std::fmt::Debug for DynamoDbLockClient {

impl DynamoDbLockClient {
/// Creates a new DynamoDbLockClient from the supplied storage options.
#[allow(clippy::too_many_arguments)]
pub fn try_new(
sdk_config: &SdkConfig,
lock_table_name: Option<String>,
Expand Down
2 changes: 1 addition & 1 deletion crates/azure/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ rust-version.workspace = true
[dependencies]
deltalake-core = { version = "0.23.0", path = "../core", features = [
"datafusion",
] }
]}
lazy_static = "1"

# workspace depenndecies
Expand Down
14 changes: 8 additions & 6 deletions crates/catalog-unity/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -17,17 +17,19 @@ tokio.workspace = true
serde.workspace = true
serde_json.workspace = true
thiserror.workspace = true
deltalake-core = { version = "0.23", path = "../core" }
deltalake-core = { version = "0.23", path = "../core", features = [
"datafusion",
]}
reqwest = { version = "0.12", default-features = false, features = ["rustls-tls", "json", "http2"] }
reqwest-retry = "0.7"
reqwest-middleware = "0.4.0"
rand = "0.8"
futures = "0.3"
chrono = "0.4"
futures = { workspace = true }
chrono = { workspace = true }
dashmap = "6"
tracing = "0.1"
datafusion = { version = "43", optional = true }
datafusion-common = { version = "43", optional = true }
tracing = { workspace = true }
datafusion = { workspace = true, optional = true }
datafusion-common = { workspace = true, optional = true }

[dev-dependencies]
tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
Expand Down
12 changes: 4 additions & 8 deletions crates/catalog-unity/src/credential.rs
Original file line number Diff line number Diff line change
Expand Up @@ -205,8 +205,7 @@ impl TokenCredential for AzureCliCredential {
"got unexpected token type from azure cli: {0}",
token_response.token_type
),
}
.into());
});
}
let duration =
token_response.expires_on.naive_local() - chrono::Local::now().naive_local();
Expand All @@ -224,18 +223,15 @@ impl TokenCredential for AzureCliCredential {
let message = String::from_utf8_lossy(&az_output.stderr);
Err(UnityCatalogError::AzureCli {
message: message.into(),
}
.into())
})
}
Err(e) => match e.kind() {
std::io::ErrorKind::NotFound => Err(UnityCatalogError::AzureCli {
message: "Azure Cli not installed".into(),
}
.into()),
}),
error_kind => Err(UnityCatalogError::AzureCli {
message: format!("io error: {error_kind:?}"),
}
.into()),
}),
},
}
}
Expand Down
3 changes: 1 addition & 2 deletions crates/catalog-unity/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -644,8 +644,7 @@ impl DataCatalog for UnityCatalog {
GetTableResponse::Error(err) => Err(UnityCatalogError::InvalidTable {
error_code: err.error_code,
message: err.message,
}
.into()),
}),
}
}
}
Expand Down
1 change: 1 addition & 0 deletions python/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -670,6 +670,7 @@ impl RawDeltaTable {
}

#[pyo3(signature = (starting_version = 0, ending_version = None, starting_timestamp = None, ending_timestamp = None, columns = None, allow_out_of_range = false))]
#[allow(clippy::too_many_arguments)]
pub fn load_cdf(
&mut self,
py: Python,
Expand Down

0 comments on commit be76272

Please sign in to comment.