This is an automated email from the ASF dual-hosted git repository.

apkhmv pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 075e6cef950 IGNITE-27504 Wait for partitions to be healthy before 
restarting them in CLI tests (#7354)
075e6cef950 is described below

commit 075e6cef950ba4be96c61e694341893e71789706
Author: Aleksandr Pakhomov <[email protected]>
AuthorDate: Wed Jan 7 15:16:39 2026 +0300

    IGNITE-27504 Wait for partitions to be healthy before restarting them in 
CLI tests (#7354)
---
 .../recovery/partitions/restart/ItRestartPartitionsTest.java | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git 
a/modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/partitions/restart/ItRestartPartitionsTest.java
 
b/modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/partitions/restart/ItRestartPartitionsTest.java
index 8cbe849b6a1..f716f81609c 100644
--- 
a/modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/partitions/restart/ItRestartPartitionsTest.java
+++ 
b/modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/partitions/restart/ItRestartPartitionsTest.java
@@ -51,7 +51,9 @@ public abstract class ItRestartPartitionsTest extends 
CliIntegrationTest {
     }
 
     @Test
-    public void testRestartAllPartitions() {
+    public void testRestartAllPartitions() throws InterruptedException {
+        awaitPartitionsToBeHealthy(ZONE, Set.of());
+
         execute(CLUSTER_URL_OPTION, NODE_URL,
                 RECOVERY_ZONE_NAME_OPTION, ZONE
         );
@@ -61,7 +63,9 @@ public abstract class ItRestartPartitionsTest extends 
CliIntegrationTest {
     }
 
     @Test
-    public void testRestartSpecifiedPartitions() {
+    public void testRestartSpecifiedPartitions() throws InterruptedException {
+        awaitPartitionsToBeHealthy(ZONE, Set.of());
+
         execute(CLUSTER_URL_OPTION, NODE_URL,
                 RECOVERY_ZONE_NAME_OPTION, ZONE,
                 RECOVERY_PARTITION_IDS_OPTION, "1,2"
@@ -72,7 +76,9 @@ public abstract class ItRestartPartitionsTest extends 
CliIntegrationTest {
     }
 
     @Test
-    public void testRestartPartitionsByNodes() {
+    public void testRestartPartitionsByNodes() throws InterruptedException {
+        awaitPartitionsToBeHealthy(ZONE, Set.of());
+
         String nodeNames = CLUSTER.runningNodes()
                 .limit(initialNodes() - 1)
                 .map(Ignite::name)

Reply via email to