Prepare 0.3.0 release

LDeakin · Feb 22, 2024 · 202dd76 · 202dd76
1 parent 3e3317d
commit 202dd76
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 10 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,6 +7,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.3.0] - 2024-02-22
+
 ### Added
  - Add benchmark data generator: `scripts/generate_benchmark_array.py`
  - Add benchmark runners: `scripts/run_benchmark/read_{all,chunks}.py`
@@ -65,7 +67,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Added
  - Initial public release
 
-[unreleased]: https://github.com/LDeakin/zarrs_tools/compare/v0.2.3...HEAD
+[unreleased]: https://github.com/LDeakin/zarrs_tools/compare/v0.3.0...HEAD
+[0.3.0]: https://github.com/LDeakin/zarrs_tools/releases/tag/v0.3.0
 [0.2.3]: https://github.com/LDeakin/zarrs_tools/releases/tag/v0.2.2
 [0.2.2]: https://github.com/LDeakin/zarrs_tools/releases/tag/v0.2.2
 [0.2.1]: https://github.com/LDeakin/zarrs_tools/releases/tag/v0.2.1

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -47,9 +47,9 @@ create-release = false
 [workspace.metadata.dist.github-custom-runners]
 aarch64-apple-darwin = "macos-14"
 
-[patch.crates-io]
+# [patch.crates-io]
 # zarrs = { path = "../zarrs" }
-zarrs = { git = "https://github.com/LDeakin/zarrs.git" }
+# zarrs = { git = "https://github.com/LDeakin/zarrs.git" }
 
 # [profile.release]
 # debug = 1
diff --git a/src/bin/zarrs_benchmark_read_async.rs b/src/bin/zarrs_benchmark_read_async.rs
@@ -118,10 +118,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                             .await
                     }
                 };
-                let spawner = async_scoped::spawner::use_tokio::Tokio::default();
-                let futures = chunk_indices
-                    .into_iter()
-                    .map(|chunk_indices| decode_chunk_into_array(chunk_indices));
+                let spawner = async_scoped::spawner::use_tokio::Tokio;
+                let futures = chunk_indices.into_iter().map(decode_chunk_into_array);
                 let mut stream = futures::stream::iter(futures)
                     .map(|future| spawner.spawn(future))
                     .buffer_unordered(chunk_concurrent_limit);

diff --git a/src/bin/zarrs_binary2zarr.rs b/src/bin/zarrs_binary2zarr.rs
@@ -134,7 +134,7 @@ fn stdin_to_array(array: &Array<FilesystemStore>, concurrent_chunks: Option<usiz
     };
     iter_concurrent_limit!(
         concurrent_chunks,
-        (0..n_blocks as usize).into_par_iter(),
+        (0..n_blocks).into_par_iter(),
         for_each,
         op
     );

diff --git a/src/bin/zarrs_ncvar2zarr.rs b/src/bin/zarrs_ncvar2zarr.rs
@@ -86,7 +86,7 @@ fn ncfiles_to_array<TStore: ReadableWritableStorageTraits + ?Sized + 'static>(
         .chunk_array_representation(&vec![0; array.chunk_grid().dimensionality()])
         .unwrap();
     let concurrent_target = std::thread::available_parallelism().unwrap().get();
-    let n_blocks = usize::try_from(nc_paths.len()).unwrap();
+    let n_blocks = nc_paths.len();
     let (concurrent_blocks, codec_concurrent_target) =
         zarrs::array::concurrency::calc_concurrency_outer_inner(
             concurrent_target,