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 7fa5221 commit 2909e6bCopy full SHA for 2909e6b
1 file changed
zarr/sync.py
@@ -5,14 +5,6 @@
5
import os
6
7
8
-import fasteners
9
-
10
11
-from zarr.core import Array
12
-from zarr.attrs import Attributes
13
-from zarr.storage import attrs_key
14
15
16
class ThreadSynchronizer(object):
17
"""Provides synchronization using thread locks."""
18
@@ -48,6 +40,7 @@ def __init__(self, path):
48
40
self.path = path
49
41
50
42
def __getitem__(self, item):
43
+ import fasteners
51
44
lock = fasteners.InterProcessLock(
52
45
os.path.join(self.path, '%s.lock' % item)
53
46
)
0 commit comments