Skip to content

Commit d42f0db

Browse files
committed
Alter block size in test so multiple queues get tested
1 parent c80645d commit d42f0db

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tests/test_igzip_threaded.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,10 +28,12 @@ def test_threaded_read():
2828

2929

3030
@pytest.mark.parametrize(["mode", "threads"],
31-
itertools.product(["wb", "wt"], [1, 3]))
31+
itertools.product(["wb", "wt"], [1, 3, 12]))
3232
def test_threaded_write(mode, threads):
3333
with tempfile.NamedTemporaryFile("wb", delete=False) as tmp:
34-
with igzip_threaded.open(tmp, mode, threads=threads) as out_file:
34+
# Use a small block size to simulate many writes.
35+
with igzip_threaded.open(tmp, mode, threads=threads,
36+
block_size=8*1024) as out_file:
3537
gzip_open_mode = "rb" if "b" in mode else "rt"
3638
with gzip.open(TEST_FILE, gzip_open_mode) as in_file:
3739
while True:

0 commit comments

Comments
 (0)