Skip to content

Commit cf3cbb3

Browse files
update sha, clippy fix
1 parent 92a08c8 commit cf3cbb3

File tree

6 files changed

+5
-7
lines changed

6 files changed

+5
-7
lines changed

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ temp-dir = "0.1.14"
161161

162162
[package.metadata.parseable_ui]
163163
assets-url = "https://parseable-prism-build.s3.us-east-2.amazonaws.com/v2.4.3/build.zip"
164-
assets-sha1 = "c902c3be71886f0ea271b7f3caed4f5b20f0aeb7"
164+
assets-sha1 = "1b7db84c0365f48870745989be0640ecfe8f06fd"
165165

166166
[features]
167167
debug = []

src/static_schema.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,8 +56,6 @@ pub struct Fields {
5656
metadata: HashMap<String, String>,
5757
}
5858

59-
#[derive(Default, Debug, Clone, PartialEq, Serialize, Deserialize)]
60-
pub struct Metadata {}
6159
pub fn convert_static_schema_to_arrow_schema(
6260
static_schema: StaticSchema,
6361
time_partition: &str,

src/storage/azure_blob.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -345,7 +345,7 @@ impl BlobStore {
345345

346346
// let mut upload_parts = Vec::new();
347347

348-
let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0;
348+
let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE);
349349
let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE;
350350
let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 };
351351

src/storage/gcs.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -324,7 +324,7 @@ impl Gcs {
324324
let mut data = Vec::new();
325325
file.read_to_end(&mut data).await?;
326326

327-
let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0;
327+
let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE);
328328
let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE;
329329
let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 };
330330

src/storage/localfs.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ impl ObjectStorage for LocalFS {
218218
async fn get_objects(
219219
&self,
220220
base_path: Option<&RelativePath>,
221-
filter_func: Box<(dyn Fn(String) -> bool + std::marker::Send + 'static)>,
221+
filter_func: Box<dyn Fn(String) -> bool + std::marker::Send + 'static>,
222222
) -> Result<Vec<Bytes>, ObjectStorageError> {
223223
let time = Instant::now();
224224

src/storage/s3.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,7 @@ impl S3 {
510510

511511
// let mut upload_parts = Vec::new();
512512

513-
let has_final_partial_part = total_size % MIN_MULTIPART_UPLOAD_SIZE > 0;
513+
let has_final_partial_part = !total_size.is_multiple_of(MIN_MULTIPART_UPLOAD_SIZE);
514514
let num_full_parts = total_size / MIN_MULTIPART_UPLOAD_SIZE;
515515
let total_parts = num_full_parts + if has_final_partial_part { 1 } else { 0 };
516516

0 commit comments

Comments
 (0)