Renaming maintenance_events to maint_notifications part 2: renaming the files.

redis/_parsers/base.py

@@ -4,7 +4,7 @@
 from asyncio import IncompleteReadError, StreamReader, TimeoutError
 from typing import Awaitable, Callable, List, Optional, Protocol, Union
 
-from redis.maintenance_events import (
+from redis.maint_notifications import (
     MaintenanceNotification,
     NodeFailedOverNotification,
     NodeFailingOverNotification,

redis/client.py

@@ -56,7 +56,7 @@
     WatchError,
 )
 from redis.lock import Lock
-from redis.maintenance_events import (
+from redis.maint_notifications import (
     MaintNotificationsConfig,
     MaintNotificationsPoolHandler,
 )

redis/connection.py

@@ -47,7 +47,7 @@
     ResponseError,
     TimeoutError,
 )
-from .maintenance_events import (
+from .maint_notifications import (
     MaintenanceState,
     MaintNotificationsConfig,
     MaintNotificationsConnectionHandler,

tests/test_maintenance_events.py → tests/test_maint_notifications.py

@@ -4,7 +4,7 @@
 
 from redis.connection import ConnectionInterface
 
-from redis.maintenance_events import (
+from redis.maint_notifications import (
     MaintenanceNotification,
     NodeMovingNotification,
     NodeMigratingNotification,

tests/test_maintenance_events_handling.py → tests/test_maint_notifications_handling.py

@@ -13,7 +13,7 @@
     BlockingConnectionPool,
     MaintenanceState,
 )
-from redis.maintenance_events import (
+from redis.maint_notifications import (
     MaintNotificationsConfig,
     NodeMigratingNotification,
     NodeMigratedNotification,
@@ -668,7 +668,7 @@ def test_pool_handler_with_migrating_notification(self):
                 patch.object(
                     pool_handler, "handle_node_moving_notification"
                 ) as mock_handle_moving,
-                patch("redis.maintenance_events.logging.error") as mock_logging_error,
+                patch("redis.maint_notifications.logging.error") as mock_logging_error,
             ):
                 # Pool handler should return None for migrating notifications (not its responsibility)
                 pool_handler.handle_notification(migrating_notification)

tests/test_scenario/conftest.py

@@ -7,7 +7,7 @@
 
 from redis.backoff import ExponentialWithJitterBackoff, NoBackoff
 from redis.client import Redis
-from redis.maintenance_events import EndpointType, MaintNotificationsConfig
+from redis.maint_notifications import EndpointType, MaintNotificationsConfig
 from redis.retry import Retry
 from tests.test_scenario.fault_injector_client import FaultInjectorClient
 

tests/test_scenario/test_hitless_upgrade.py → tests/test_scenario/test_maint_notifications.py

@@ -12,7 +12,7 @@
 
 from redis import Redis
 from redis.connection import ConnectionInterface
-from redis.maintenance_events import (
+from redis.maint_notifications import (
     EndpointType,
     MaintNotificationsConfig,
     MaintenanceState,
@@ -25,14 +25,15 @@
 from tests.test_scenario.fault_injector_client import (
     FaultInjectorClient,
 )
-from tests.test_scenario.hitless_upgrade_helpers import (
+from tests.test_scenario.maint_notifications_helpers import (
     ClientValidations,
     ClusterOperations,
 )
 
 logging.basicConfig(
     level=logging.INFO,
     format="%(asctime)s %(levelname)s %(message)s",
+    datefmt="%Y-%m-%d %H:%M:%S:%f",
 )
 
 BIND_TIMEOUT = 30