Troubleshoot failing CI test (passing locally)

redis · Dec 3, 2024 · 51c95ed · 51c95ed
1 parent e04a01d
commit 51c95ed
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/...va/io/lettuce/core/cluster/RedisClusterStreamingCredentialsProviderlIntegrationTests.java b/...va/io/lettuce/core/cluster/RedisClusterStreamingCredentialsProviderlIntegrationTests.java
@@ -143,8 +143,8 @@ void nodeSelectionApiShouldWork() {
     void shouldPerformNodeConnectionReauth() {
 
         try (StatefulRedisClusterConnection<String, String> connection = redisClient.connect()) {
-            connection.getPartitions().forEach(
-                    partition -> createTestUser(connection.getConnection(partition.getNodeId()).sync()));
+            connection.getPartitions()
+                    .forEach(partition -> createTestUser(connection.getConnection(partition.getNodeId()).sync()));
 
             credentialsProvider.emitCredentials(TestSettings.aclUsername(),
                     TestSettings.aclPassword().toString().toCharArray());
@@ -158,14 +158,14 @@ void shouldPerformNodeConnectionReauth() {
                 assertThat(authenticatedUser).isEqualTo(TestSettings.aclUsername());
             });
 
-            connection.getPartitions().forEach(
-                    partition -> deleteTestUser(connection.getConnection(partition.getNodeId()).sync()));
+            connection.getPartitions()
+                    .forEach(partition -> deleteTestUser(connection.getConnection(partition.getNodeId()).sync()));
         }
     }
 
     public static void createTestUser(RedisCommands<String, String> commands) {
-        Command<String, String, List<Object>> command = CliParser.parse(
-                "ACL SETUSER " + TestSettings.aclUsername() + " on >" + TestSettings.aclPassword() + " ~cached:* +@all");
+        Command<String, String, List<Object>> command = CliParser
+                .parse("ACL SETUSER " + TestSettings.aclUsername() + " on >" + TestSettings.aclPassword() + " ~cached:* +@all");
         commands.dispatch(command.getType(), command.getOutput(), command.getArgs());
     }
 
@@ -174,4 +174,5 @@ public static void deleteTestUser(RedisCommands<String, String> commands) {
         commands.dispatch(command.getType(), command.getOutput(), command.getArgs());
 
     }
+
 }