diff --git a/Cargo.lock b/Cargo.lock index e94d14be2..81afe87bf 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3458,7 +3458,7 @@ dependencies = [ [[package]] name = "parseable" -version = "2.4.2" +version = "2.4.3" dependencies = [ "actix-cors", "actix-web", diff --git a/Cargo.toml b/Cargo.toml index 2ca519ce5..6604a03fe 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "parseable" -version = "2.4.2" +version = "2.4.3" authors = ["Parseable Team "] edition = "2024" rust-version = "1.88.0" @@ -160,8 +160,8 @@ arrow = "54.0.0" temp-dir = "0.1.14" [package.metadata.parseable_ui] -assets-url = "https://parseable-prism-build.s3.us-east-2.amazonaws.com/v2.4.2/build.zip" -assets-sha1 = "218c43d9bb75e8f9a15df544763a874e65fa0f40" +assets-url = "https://parseable-prism-build.s3.us-east-2.amazonaws.com/v2.4.3/build.zip" +assets-sha1 = "1b7db84c0365f48870745989be0640ecfe8f06fd" [features] debug = [] diff --git a/src/static_schema.rs b/src/static_schema.rs index 744dc77b9..72e2c11be 100644 --- a/src/static_schema.rs +++ b/src/static_schema.rs @@ -56,8 +56,6 @@ pub struct Fields { metadata: HashMap, } -#[derive(Default, Debug, Clone, PartialEq, Serialize, Deserialize)] -pub struct Metadata {} pub fn convert_static_schema_to_arrow_schema( static_schema: StaticSchema, time_partition: &str, diff --git a/src/storage/azure_blob.rs b/src/storage/azure_blob.rs index c05aabd59..acd867361 100644 --- a/src/storage/azure_blob.rs +++ b/src/storage/azure_blob.rs @@ -345,7 +345,7 @@ impl BlobStore { // let mut upload_parts = Vec::new(); - let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0; + let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE); let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE; let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 }; diff --git a/src/storage/gcs.rs b/src/storage/gcs.rs index 58bece752..307359b51 100644 --- a/src/storage/gcs.rs +++ b/src/storage/gcs.rs @@ -324,7 +324,7 @@ impl Gcs { let mut data = Vec::new(); file.read_to_end(&mut data).await?; - let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0; + let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE); let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE; let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 }; diff --git a/src/storage/localfs.rs b/src/storage/localfs.rs index 3629af621..8157c2b41 100644 --- a/src/storage/localfs.rs +++ b/src/storage/localfs.rs @@ -218,7 +218,7 @@ impl ObjectStorage for LocalFS { async fn get_objects( &self, base_path: Option<&RelativePath>, - filter_func: Box<(dyn Fn(String) -> bool + std::marker::Send + 'static)>, + filter_func: Box bool + std::marker::Send + 'static>, ) -> Result, ObjectStorageError> { let time = Instant::now(); diff --git a/src/storage/s3.rs b/src/storage/s3.rs index 1a7817321..bc8d57a63 100644 --- a/src/storage/s3.rs +++ b/src/storage/s3.rs @@ -510,7 +510,7 @@ impl S3 { // let mut upload_parts = Vec::new(); - let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0; + let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE); let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE; let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 };