diff --git a/client/src/storage_client.rs b/client/src/storage_client.rs index e7c112c..a39a77a 100644 --- a/client/src/storage_client.rs +++ b/client/src/storage_client.rs @@ -185,6 +185,7 @@ impl StorageClientImpl { file.write_all(&file_contents)?; println!("parquet written to {}", file_path); + if dup_id > 0 { Ok(file_name.to_string() + dup_id.to_string().as_str()) } else {