Use donfig for V3 configuration (#1855)

* Use donfig for sync configuration

* Consolidate concurrency config

* Remove unused parameter

* finish removing runtime config

 -- a few todos remain

* fix order constructor

* add basic tests for config state

* add order property to Array

* update comment in sharding codec

---------

Co-authored-by: Joseph Hamman <joe@earthmover.io>

Author: maxrjones

pyproject.toml

@@ -19,6 +19,7 @@ dependencies = [
     'crc32c',
     'zstandard',
     'typing_extensions',
+    'donfig'
 ]
 dynamic = [
   "version",

src/zarr/__init__.py

@@ -5,9 +5,8 @@
 import zarr.codecs  # noqa: F401
 from zarr.array import Array, AsyncArray  # noqa: F401
 from zarr.array_v2 import ArrayV2
-from zarr.config import RuntimeConfiguration  # noqa: F401
+from zarr.config import config  # noqa: F401
 from zarr.group import AsyncGroup, Group  # noqa: F401
-from zarr.metadata import runtime_configuration  # noqa: F401
 from zarr.store import (  # noqa: F401
     StoreLike,
     make_store_path,
@@ -21,22 +20,19 @@
 
 async def open_auto_async(
     store: StoreLike,
-    runtime_configuration_: RuntimeConfiguration = RuntimeConfiguration(),
 ) -> Union[AsyncArray, AsyncGroup]:
     store_path = make_store_path(store)
     try:
-        return await AsyncArray.open(store_path, runtime_configuration=runtime_configuration_)
+        return await AsyncArray.open(store_path)
     except KeyError:
-        return await AsyncGroup.open(store_path, runtime_configuration=runtime_configuration_)
+        return await AsyncGroup.open(store_path)
 
 
 def open_auto(
     store: StoreLike,
-    runtime_configuration_: RuntimeConfiguration = RuntimeConfiguration(),
 ) -> Union[Array, ArrayV2, Group]:
     object = _sync(
-        open_auto_async(store, runtime_configuration_),
-        runtime_configuration_.asyncio_loop,
+        open_auto_async(store),
     )
     if isinstance(object, AsyncArray):
         return Array(object)

src/zarr/abc/codec.py

@@ -14,7 +14,6 @@
     from typing_extensions import Self
     from zarr.common import BytesLike, SliceSelection
     from zarr.metadata import ArrayMetadata
-    from zarr.config import RuntimeConfiguration
 
 
 class Codec(Metadata):
@@ -40,7 +39,6 @@ async def decode(
         self,
         chunk_array: np.ndarray,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> np.ndarray:
         pass
 
@@ -49,7 +47,6 @@ async def encode(
         self,
         chunk_array: np.ndarray,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> Optional[np.ndarray]:
         pass
 
@@ -60,7 +57,6 @@ async def decode(
         self,
         chunk_array: BytesLike,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> np.ndarray:
         pass
 
@@ -69,7 +65,6 @@ async def encode(
         self,
         chunk_array: np.ndarray,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> Optional[BytesLike]:
         pass
 
@@ -81,7 +76,6 @@ async def decode_partial(
         store_path: StorePath,
         selection: SliceSelection,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> Optional[np.ndarray]:
         pass
 
@@ -94,7 +88,6 @@ async def encode_partial(
         chunk_array: np.ndarray,
         selection: SliceSelection,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> None:
         pass
 
@@ -105,7 +98,6 @@ async def decode(
         self,
         chunk_array: BytesLike,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> BytesLike:
         pass
 
@@ -114,6 +106,5 @@ async def encode(
         self,
         chunk_array: BytesLike,
         chunk_spec: ArraySpec,
-        runtime_configuration: RuntimeConfiguration,
     ) -> Optional[BytesLike]:
         pass