@@ -1528,17 +1528,17 @@ def test_moving_migrating_migrated_moved_state_transitions(self, pool_class):
15281528 NodeFailingOverEvent (id = 3 , ttl = 1 )
15291529 )
15301530 # State should not change for connections that are in MOVING state
1531- self . _validate_in_use_connections_state (
1531+ Helpers . validate_in_use_connections_state (
15321532 in_use_connections ,
15331533 expected_state = MaintenanceState .MOVING ,
15341534 expected_host_address = tmp_address ,
15351535 expected_socket_timeout = self .config .relax_timeout ,
15361536 expected_socket_connect_timeout = self .config .relax_timeout ,
1537- expected_orig_host_address = MockSocket . DEFAULT_ADDRESS .split (":" )[0 ],
1537+ expected_orig_host_address = DEFAULT_ADDRESS .split (":" )[0 ],
15381538 expected_orig_socket_timeout = None ,
15391539 expected_orig_socket_connect_timeout = None ,
15401540 expected_current_socket_timeout = self .config .relax_timeout ,
1541- expected_current_peername = MockSocket . DEFAULT_ADDRESS .split (":" )[0 ],
1541+ expected_current_peername = DEFAULT_ADDRESS .split (":" )[0 ],
15421542 )
15431543
15441544 # 5. FAILED_OVER event (simulate direct connection handler call)
@@ -1547,17 +1547,17 @@ def test_moving_migrating_migrated_moved_state_transitions(self, pool_class):
15471547 NodeFailedOverEvent (id = 3 )
15481548 )
15491549 # State should not change for connections that are in MOVING state
1550- self . _validate_in_use_connections_state (
1550+ Helpers . validate_in_use_connections_state (
15511551 in_use_connections ,
15521552 expected_state = MaintenanceState .MOVING ,
15531553 expected_host_address = tmp_address ,
15541554 expected_socket_timeout = self .config .relax_timeout ,
15551555 expected_socket_connect_timeout = self .config .relax_timeout ,
1556- expected_orig_host_address = MockSocket . DEFAULT_ADDRESS .split (":" )[0 ],
1556+ expected_orig_host_address = DEFAULT_ADDRESS .split (":" )[0 ],
15571557 expected_orig_socket_timeout = None ,
15581558 expected_orig_socket_connect_timeout = None ,
15591559 expected_current_socket_timeout = self .config .relax_timeout ,
1560- expected_current_peername = MockSocket . DEFAULT_ADDRESS .split (":" )[0 ],
1560+ expected_current_peername = DEFAULT_ADDRESS .split (":" )[0 ],
15611561 )
15621562
15631563 # 6. MOVED event (simulate timer expiry)
0 commit comments