Try fix flacky test_concurrent_alter_move_and_drop

This commit is contained in:
serxa 2023-04-17 10:33:59 +00:00
parent 90ebdedfdd
commit 4370abf3c4

View File

@ -1262,13 +1262,13 @@ def test_concurrent_alter_move_and_drop(start_cluster, name, engine):
else:
raise e
insert(100)
insert(20)
p = Pool(15)
tasks = []
for i in range(5):
tasks.append(p.apply_async(insert, (100,)))
tasks.append(p.apply_async(alter_move, (100,)))
tasks.append(p.apply_async(alter_drop, (100,)))
tasks.append(p.apply_async(insert, (20,)))
tasks.append(p.apply_async(alter_move, (20,)))
tasks.append(p.apply_async(alter_drop, (20,)))
for task in tasks:
task.get(timeout=120)