chore: bump rust dependencies (#128)

- pyo3 to 0.27.1
- pyo3-stub-gen to 0.17.1
- numpy to 0.27.0

Author: LDeakin

Cargo.toml

@@ -9,16 +9,16 @@ name = "zarrs_python"
 crate-type = ["cdylib", "rlib"]
 
 [dependencies]
-pyo3 = { version = "0.25.1", features = ["abi3-py311"] }
+pyo3 = { version = "0.27.1", features = ["abi3-py311"] }
 zarrs = { version = "0.22.4", features = ["async", "zlib", "pcodec", "bz2"] }
 rayon_iter_concurrent_limit = "0.2.0"
 rayon = "1.10.0"
 # fix for https://stackoverflow.com/questions/76593417/package-openssl-was-not-found-in-the-pkg-config-search-path
 openssl = { version = "0.10", features = ["vendored"] }
-numpy = "0.25.0"
+numpy = "0.27.0"
 unsafe_cell_slice = "0.2.0"
 serde_json = "1.0.128"
-pyo3-stub-gen = "0.12.2"
+pyo3-stub-gen = "0.17.1"
 opendal = { version = "0.54.0", features = ["services-http"] }
 tokio = { version = "1.41.1", features = ["rt-multi-thread"] }
 zarrs_opendal = "0.9.0"

python/zarrs/_internal.pyi

@@ -7,9 +7,11 @@ import typing
 import numpy.typing
 import zarr.abc.store
 
+@typing.final
 class Basic:
     def __new__(cls, byte_interface: typing.Any, chunk_spec: typing.Any) -> Basic: ...
 
+@typing.final
 class CodecPipelineImpl:
     def __new__(
         cls,
@@ -34,6 +36,7 @@ class CodecPipelineImpl:
         write_empty_chunks: builtins.bool,
     ) -> None: ...
 
+@typing.final
 class WithSubset:
     def __new__(
         cls,

src/chunk_item.rs

@@ -33,7 +33,7 @@ fn fill_value_to_bytes(dtype: &str, fill_value: &Bound<'_, PyAny>) -> PyResult<V
     if dtype == "string" {
         // Match zarr-python 2.x.x string fill value behaviour with a 0 fill value
         // See https://github.com/zarr-developers/zarr-python/issues/2792#issuecomment-2644362122
-        if let Ok(fill_value_downcast) = fill_value.downcast::<PyInt>() {
+        if let Ok(fill_value_downcast) = fill_value.cast::<PyInt>() {
             let fill_value_usize: usize = fill_value_downcast.extract()?;
             if fill_value_usize == 0 {
                 return Ok(vec![]);
@@ -44,7 +44,7 @@ fn fill_value_to_bytes(dtype: &str, fill_value: &Bound<'_, PyAny>) -> PyResult<V
         }
     }
 
-    if let Ok(fill_value_downcast) = fill_value.downcast::<PyBytes>() {
+    if let Ok(fill_value_downcast) = fill_value.cast::<PyBytes>() {
         Ok(fill_value_downcast.as_bytes().to_vec())
     } else if fill_value.hasattr("tobytes")? {
         Ok(fill_value.call_method0("tobytes")?.extract()?)

src/lib.rs

@@ -341,7 +341,7 @@ impl CodecPipelineImpl {
             partial_decoder_cache.extend(key_decoder_pairs);
         }
 
-        py.allow_threads(move || {
+        py.detach(move || {
             // FIXME: the `decode_into` methods only support fixed length data types.
             // For variable length data types, need a codepath with non `_into` methods.
             // Collect all the subsets and copy into value on the Python side?
@@ -448,7 +448,7 @@ impl CodecPipelineImpl {
         };
         codec_options.set_store_empty_chunks(write_empty_chunks);
 
-        py.allow_threads(move || {
+        py.detach(move || {
             let store_chunk = |item: chunk_item::WithSubset| match &input {
                 InputValue::Array(input) => {
                     let chunk_subset_bytes = input

src/store.rs

@@ -2,7 +2,7 @@ use std::{collections::HashMap, sync::Arc};
 
 use opendal::Builder;
 use pyo3::{
-    Bound, FromPyObject, PyAny, PyErr, PyResult,
+    Borrowed, Bound, FromPyObject, PyAny, PyErr, PyResult,
     exceptions::{PyNotImplementedError, PyValueError},
     types::{PyAnyMethods, PyStringMethods, PyTypeMethods},
 };
@@ -25,8 +25,10 @@ pub enum StoreConfig {
     // TODO: Add support for more stores
 }
 
-impl<'py> FromPyObject<'py> for StoreConfig {
-    fn extract_bound(store: &Bound<'py, PyAny>) -> PyResult<Self> {
+impl<'py> FromPyObject<'_, 'py> for StoreConfig {
+    type Error = PyErr;
+
+    fn extract(store: Borrowed<'_, 'py, PyAny>) -> PyResult<Self> {
         let name = store.get_type().name()?;
         let name = name.to_str()?;
         match name {