Fixing lint errors

Author: petyaslavova

redis/connection.py

@@ -2018,9 +2018,7 @@ def update_active_connections_for_reconnect(
         :param tmp_relax_timeout: The relax timeout to use for the connection.
         """
         for conn in self._in_use_connections:
-            if self.should_update_connection(
-                conn, "connected", moving_address_src
-            ):
+            if self.should_update_connection(conn, "connected", moving_address_src):
                 self._update_connection_for_reconnect(
                     conn, tmp_host_address, tmp_relax_timeout
                 )
@@ -2042,9 +2040,7 @@ def disconnect_and_reconfigure_free_connections(
         """
 
         for conn in self._available_connections:
-            if self.should_update_connection(
-                conn, "connected", moving_address_src
-            ):
+            if self.should_update_connection(conn, "connected", moving_address_src):
                 self._disconnect_and_update_connection_for_reconnect(
                     conn, tmp_host_address, tmp_relax_timeout
                 )
@@ -2312,15 +2308,15 @@ def disconnect(self):
                 self._locked = False
 
     def update_connections_settings(
-            self,
-            state: Optional["MaintenanceState"] = None,
-            relax_timeout: Optional[float] = None,
-            matching_address: Optional[str] = None,
-            address_type_to_match: Literal["connected", "configured"] = "connected",
-            reset_host_address: bool = False,
-            reset_relax_timeout: bool = False,
-            include_free_connections: bool = True,
-        ):
+        self,
+        state: Optional["MaintenanceState"] = None,
+        relax_timeout: Optional[float] = None,
+        matching_address: Optional[str] = None,
+        address_type_to_match: Literal["connected", "configured"] = "connected",
+        reset_host_address: bool = False,
+        reset_relax_timeout: bool = False,
+        include_free_connections: bool = True,
+    ):
         """
         Override base class method to work with BlockingConnectionPool's structure.
         """
@@ -2424,4 +2420,3 @@ def set_in_maintenance(self, in_maintenance: bool):
         The pool will be in maintenance mode only when we are processing a MOVING event.
         """
         self._in_maintenance = in_maintenance
-

redis/maintenance_events.py

@@ -378,20 +378,20 @@ def handle_node_moving_event(self, event: NodeMovingEvent):
                     )
 
                     if self.config.proactive_reconnect:
-                            # take care for the active connections in the pool
-                            # mark them for reconnect after they complete the current command
-                            self.pool.update_active_connections_for_reconnect(
-                                tmp_host_address=event.new_node_host,
-                                tmp_relax_timeout=self.config.relax_timeout,
-                                moving_address_src=moving_address_src,
-                            )
-                            # take care for the inactive connections in the pool
-                            # delete them and create new ones
-                            self.pool.disconnect_and_reconfigure_free_connections(
-                                tmp_host_address=event.new_node_host,
-                                tmp_relax_timeout=self.config.relax_timeout,
-                                moving_address_src=moving_address_src,
-                            )
+                        # take care for the active connections in the pool
+                        # mark them for reconnect after they complete the current command
+                        self.pool.update_active_connections_for_reconnect(
+                            tmp_host_address=event.new_node_host,
+                            tmp_relax_timeout=self.config.relax_timeout,
+                            moving_address_src=moving_address_src,
+                        )
+                        # take care for the inactive connections in the pool
+                        # delete them and create new ones
+                        self.pool.disconnect_and_reconfigure_free_connections(
+                            tmp_host_address=event.new_node_host,
+                            tmp_relax_timeout=self.config.relax_timeout,
+                            moving_address_src=moving_address_src,
+                        )
 
                     # Update config for new connections:
                     # Set state to MOVING
@@ -426,8 +426,12 @@ def handle_node_moved_event(self, event: NodeMovingEvent):
             # and we don't need to revert the kwargs
             if self.pool.connection_kwargs.get("host") == event.new_node_host:
                 orig_host = self.pool.connection_kwargs.get("orig_host_address")
-                orig_socket_timeout = self.pool.connection_kwargs.get("orig_socket_timeout")
-                orig_connect_timeout = self.pool.connection_kwargs.get("orig_socket_connect_timeout")
+                orig_socket_timeout = self.pool.connection_kwargs.get(
+                    "orig_socket_timeout"
+                )
+                orig_connect_timeout = self.pool.connection_kwargs.get(
+                    "orig_socket_connect_timeout"
+                )
                 kwargs: dict = {
                     "maintenance_state": MaintenanceState.NONE,
                     "host": orig_host,