fix: return store directly from opendal_builder_to_sync_store

src/store.rs

@@ -15,12 +15,8 @@ use zarrs::storage::{
     storage_adapter::async_to_sync::AsyncToSyncStorageAdapter,
     ReadableWritableListableStorageTraits,
 };
-use zarrs_opendal::AsyncOpendalStore;
 
-use crate::{
-    runtime::{tokio_block_on, TokioBlockOn},
-    utils::PyErrExt,
-};
+use crate::{runtime::tokio_block_on, utils::PyErrExt};
 
 mod filesystem;
 mod http;
@@ -82,9 +78,9 @@ impl TryFrom<&StoreConfigType> for Arc<dyn ReadableWritableListableStorageTraits
     }
 }
 
-type OpendalStoreSync = Arc<AsyncToSyncStorageAdapter<AsyncOpendalStore, TokioBlockOn>>;
-
-fn opendal_builder_to_sync_store<B: Builder>(builder: B) -> PyResult<OpendalStoreSync> {
+fn opendal_builder_to_sync_store<B: Builder>(
+    builder: B,
+) -> PyResult<Arc<dyn ReadableWritableListableStorageTraits>> {
     let operator = opendal::Operator::new(builder)
         .map_py_err::<PyValueError>()?
         .finish();

src/store/filesystem.rs

@@ -24,7 +24,7 @@ impl TryInto<Arc<dyn ReadableWritableListableStorageTraits>> for &FilesystemStor
     type Error = PyErr;
 
     fn try_into(self) -> Result<Arc<dyn ReadableWritableListableStorageTraits>, Self::Error> {
-        let store: Arc<dyn ReadableWritableListableStorageTraits> =
+        let store =
             Arc::new(FilesystemStore::new(self.root.clone()).map_py_err::<PyRuntimeError>()?);
         Ok(store)
     }

src/store/http.rs

@@ -39,8 +39,6 @@ impl TryInto<Arc<dyn ReadableWritableListableStorageTraits>> for &HttpStoreConfi
 
     fn try_into(self) -> Result<Arc<dyn ReadableWritableListableStorageTraits>, Self::Error> {
         let builder = opendal::services::Http::default().endpoint(&self.root);
-        let store: Arc<dyn ReadableWritableListableStorageTraits> =
-            opendal_builder_to_sync_store(builder)?;
-        Ok(store)
+        opendal_builder_to_sync_store(builder)
     }
 }