@@ -1471,7 +1471,6 @@ async def test_migration_with_key_ttl(df_factory):
1471
1471
assert await nodes [1 ].client .execute_command ("stick k_sticky" ) == 0
1472
1472
1473
1473
1474
- @pytest .mark .exclude_epoll
1475
1474
@dfly_args ({"proactor_threads" : 4 , "cluster_mode" : "yes" , "migration_finalization_timeout_ms" : 5 })
1476
1475
async def test_network_disconnect_during_migration (df_factory ):
1477
1476
instances = [
@@ -2029,7 +2028,6 @@ async def start_save():
2029
2028
# We can try to use FakeRedis with the DebugPopulateSeeder comparison here.
2030
2029
2031
2030
2032
- @pytest .mark .exclude_epoll
2033
2031
@dfly_args ({"proactor_threads" : 4 , "cluster_mode" : "yes" })
2034
2032
@pytest .mark .asyncio
2035
2033
async def test_cluster_migration_cancel (df_factory : DflyInstanceFactory ):
@@ -2095,7 +2093,6 @@ async def node1size0():
2095
2093
@dfly_args ({"proactor_threads" : 2 , "cluster_mode" : "yes" })
2096
2094
@pytest .mark .asyncio
2097
2095
@pytest .mark .opt_only
2098
- @pytest .mark .exclude_epoll
2099
2096
async def test_cluster_migration_huge_container (df_factory : DflyInstanceFactory ):
2100
2097
instances = [
2101
2098
df_factory .create (port = next (next_port ), admin_port = next (next_port )) for i in range (2 )
@@ -2157,7 +2154,6 @@ async def test_cluster_migration_huge_container(df_factory: DflyInstanceFactory)
2157
2154
)
2158
2155
@pytest .mark .parametrize ("chunk_size" , [1_000_000 , 30 ])
2159
2156
@pytest .mark .asyncio
2160
- @pytest .mark .exclude_epoll
2161
2157
async def test_cluster_migration_while_seeding (
2162
2158
df_factory : DflyInstanceFactory , df_seeder_factory : DflySeederFactory , chunk_size
2163
2159
):
@@ -2305,7 +2301,6 @@ async def await_no_lag(client: aioredis.Redis, timeout=10):
2305
2301
raise RuntimeError ("Lag did not reduced to 0!" )
2306
2302
2307
2303
2308
- @pytest .mark .exclude_epoll
2309
2304
@dfly_args ({"proactor_threads" : 4 })
2310
2305
async def test_replicate_cluster (df_factory : DflyInstanceFactory , df_seeder_factory ):
2311
2306
"""
@@ -2515,7 +2510,6 @@ async def await_eq_offset(client: aioredis.Redis, timeout=20):
2515
2510
raise RuntimeError ("offset not equal!" )
2516
2511
2517
2512
2518
- @pytest .mark .exclude_epoll
2519
2513
@dfly_args ({"proactor_threads" : 4 })
2520
2514
async def test_replicate_redis_cluster (redis_cluster , df_factory , df_seeder_factory ):
2521
2515
"""
@@ -2721,7 +2715,6 @@ async def test_cluster_memory_consumption_migration(df_factory: DflyInstanceFact
2721
2715
await check_for_no_state_status ([node .admin_client for node in nodes ])
2722
2716
2723
2717
2724
- @pytest .mark .exclude_epoll
2725
2718
@pytest .mark .asyncio
2726
2719
@dfly_args ({"proactor_threads" : 4 , "cluster_mode" : "yes" , "migration_buckets_cpu_budget" : 1 })
2727
2720
async def test_migration_timeout_on_sync (df_factory : DflyInstanceFactory , df_seeder_factory ):
@@ -2881,7 +2874,6 @@ async def test_migration_one_after_another(df_factory: DflyInstanceFactory, df_s
2881
2874
2882
2875
2883
2876
@pytest .mark .slow
2884
- @pytest .mark .exclude_epoll
2885
2877
@pytest .mark .asyncio
2886
2878
@dfly_args ({"proactor_threads" : 4 , "cluster_mode" : "yes" , "pause_wait_timeout" : 10 })
2887
2879
async def test_migration_rebalance_node (df_factory : DflyInstanceFactory , df_seeder_factory ):
0 commit comments