mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

test: skip test_network_disconnect_during_migration (#4359)

Browse source
This commit is contained in:
Borys 2024-12-24 10:21:03 +02:00 • committed by GitHub
parent aeeb625393
commit dc81594cd5
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/server/cluster/incoming_slot_migration.cc
View file

@ -185,7 +185,8 @@ bool IncomingSlotMigration::Join(long attempt) {
while (true) { while (true) {
const absl::Time now = absl::Now(); const absl::Time now = absl::Now();
const absl::Duration passed = now - start; 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) { if (passed >= timeout) {
LOG(WARNING) << "Can't join migration in time for " << source_id_; LOG(WARNING) << "Can't join migration in time for " << source_id_;
ReportError(GenericError("Can't join migration in time")); ReportError(GenericError("Can't join migration in time"));

1
tests/dragonfly/cluster_test.py
View file

@ -1433,6 +1433,7 @@ async def test_migration_with_key_ttl(df_factory):
assert await nodes[1].client.execute_command("stick k_sticky") == 0 assert await nodes[1].client.execute_command("stick k_sticky") == 0
@pytest.mark.skip("Flaky test")
@dfly_args({"proactor_threads": 4, "cluster_mode": "yes"}) @dfly_args({"proactor_threads": 4, "cluster_mode": "yes"})
async def test_network_disconnect_during_migration(df_factory): async def test_network_disconnect_during_migration(df_factory):
instances = [ instances = [