Skip to content

Commit acff63c

Browse files
committed
add async timeout
1 parent c971e96 commit acff63c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

zarr/tests/test_sync.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ def test_parallel_setitem(self):
8888

8989
# parallel setitem
9090
results = pool.map_async(_set_arange, zip([arr] * n, range(n)))
91-
print(results.get())
91+
print(results.get(20))
9292

9393
assert_array_equal(np.arange(n * 1000), arr[:])
9494

@@ -102,7 +102,7 @@ def test_parallel_append(self):
102102

103103
# parallel append
104104
results = pool.map_async(_append, zip([arr] * n, range(n)))
105-
print(results.get())
105+
print(results.get(20))
106106

107107
eq(((n+1)*1000,), arr.shape)
108108

@@ -188,7 +188,7 @@ def test_parallel_create_group(self):
188188
n = 1000
189189
results = pool.map_async(
190190
_create_group, zip([g] * n, [str(i) for i in range(n)]))
191-
print(results.get())
191+
print(results.get(20))
192192

193193
eq(n, len(g))
194194

@@ -202,7 +202,7 @@ def test_parallel_require_group(self):
202202
n = 1000
203203
results = pool.map_async(
204204
_require_group, zip([g] * n, [str(i//10) for i in range(n)]))
205-
print(results.get())
205+
print(results.get(20))
206206

207207
eq(n//10, len(g))
208208

0 commit comments

Comments
 (0)