From dc81594cd5b586b502dee6426da69a4afa177a40 Mon Sep 17 00:00:00 2001 From: Borys Date: Tue, 24 Dec 2024 10:21:03 +0200 Subject: [PATCH] test: skip test_network_disconnect_during_migration (#4359) --- src/server/cluster/incoming_slot_migration.cc | 3 ++- tests/dragonfly/cluster_test.py | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/server/cluster/incoming_slot_migration.cc b/src/server/cluster/incoming_slot_migration.cc index fc9b16245..0ed07768a 100644 --- a/src/server/cluster/incoming_slot_migration.cc +++ b/src/server/cluster/incoming_slot_migration.cc @@ -185,7 +185,8 @@ bool IncomingSlotMigration::Join(long attempt) { while (true) { const absl::Time now = absl::Now(); const absl::Duration passed = now - start; - VLOG(1) << "Checking whether to continue with join " << passed << " vs " << timeout; + VLOG_EVERY_N(1, 10000) << "Checking whether to continue with join " << passed << " vs " + << timeout; if (passed >= timeout) { LOG(WARNING) << "Can't join migration in time for " << source_id_; ReportError(GenericError("Can't join migration in time")); diff --git a/tests/dragonfly/cluster_test.py b/tests/dragonfly/cluster_test.py index 6b0b5138c..230dc710d 100644 --- a/tests/dragonfly/cluster_test.py +++ b/tests/dragonfly/cluster_test.py @@ -1433,6 +1433,7 @@ async def test_migration_with_key_ttl(df_factory): assert await nodes[1].client.execute_command("stick k_sticky") == 0 +@pytest.mark.skip("Flaky test") @dfly_args({"proactor_threads": 4, "cluster_mode": "yes"}) async def test_network_disconnect_during_migration(df_factory): instances = [