We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4905708 commit 28a28d9Copy full SHA for 28a28d9
src/mdio/optimize/patch.py
@@ -11,7 +11,6 @@
11
from typing import TYPE_CHECKING
12
13
import numpy as np
14
-import zarr
15
from numcodecs import blosc
16
from zarr.codecs import numcodecs
17
@@ -48,7 +47,6 @@ class MonkeyPatchZfpDaskPlugin(distributed.WorkerPlugin):
48
47
"""
49
50
def setup(self, worker: distributed.Worker) -> None: # noqa: ARG002
51
- """Monkey patch ZFP codec and disable Blosc threading and zarr concurrency."""
+ """Monkey patch ZFP codec and disable Blosc threading."""
52
numcodecs._codecs.ZFPY = ZFPY
53
- zarr.config.set({"async.concurrency": 1})
54
blosc.set_nthreads(1)
0 commit comments