|
14 | 14 | # to verify that refresh works correctly with custom page_io_step_size |
15 | 15 |
|
16 | 16 | pytestmark = pytest.mark.parametrize("db0_fixture", [ |
17 | | - {}, # default parameters |
18 | | - {"page_io_step_size": 16 << 10} # with custom page_io_step_size |
| 17 | + {"autocommit":False}, # default parameters |
| 18 | + {"autocommit":False, "page_io_step_size": 16 << 10} # with custom page_io_step_size |
19 | 19 | ], indirect=True) |
20 | 20 |
|
21 | 21 |
|
@@ -471,13 +471,13 @@ async def test_async_wait_for_updates(db0_fixture): |
471 | 471 | # Start waiting before transactions complete |
472 | 472 | current_num = db0.get_state_num(prefix) |
473 | 473 | make_trasaction(writer_sem, 5) |
474 | | - assert await with_timeout(db0.async_wait(prefix, current_num + 5), 1) |
| 474 | + assert await with_timeout(db0.async_wait(prefix, current_num + 5), 2) |
475 | 475 |
|
476 | 476 | # Start waiting after transactions complete |
477 | 477 | current_num = db0.get_state_num(prefix) |
478 | 478 | make_trasaction(writer_sem, 2) |
479 | 479 | time.sleep(0.5) |
480 | | - assert await with_timeout(db0.async_wait(prefix, current_num + 1), 1) |
| 480 | + assert await with_timeout(db0.async_wait(prefix, current_num + 2), 1) |
481 | 481 |
|
482 | 482 | current_num = db0.get_state_num(prefix) |
483 | 483 | # Wait current state |
|
0 commit comments