We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6febeaf commit 17c7226Copy full SHA for 17c7226
1 file changed
src/zarr/storage/_utils.py
@@ -45,6 +45,14 @@ def with_concurrency_limit() -> Callable[
45
Examples
46
--------
47
```python
48
+ import asyncio
49
+ from zarr.abc.store import Store
50
+ from zarr.abc.buffer import Buffer
51
+ from zarr.storage._utils import with_concurrency_limit
52
+
53
+ async def expensive_io_operation(key: str):
54
+ asyncio.sleep(10)
55
56
class MyStore(Store):
57
def __init__(self, concurrency_limit: int = 100):
58
self._semaphore = asyncio.Semaphore(concurrency_limit) if concurrency_limit else None
0 commit comments