remove assert

tlrx · tlrx · commit 664b7398002c · 2026-03-27T17:46:20.000+01:00
diff --git a/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/TSDBSyntheticIdsIT.java b/modules/data-streams/src/internalClusterTest/java/org/elasticsearch/datastreams/TSDBSyntheticIdsIT.java
@@ -1762,13 +1762,10 @@ public void testNoopTombstones() throws Exception {
             flush(backingIndex);
         }
 
-        // Ensure all operations are replicated
-        assertBusy(() -> {
-            var replicaShard = internalCluster().getInstance(IndicesService.class, replicaNodeName).getShardOrNull(shardId);
-            assertThat(replicaShard, notNullValue());
-            long expectedMaxSeqNo = totalDocs - 1 + nbGaps;
-            assertThat(replicaShard.withEngine(engine -> engine.getSeqNoStats(-1).getMaxSeqNo()), equalTo(expectedMaxSeqNo));
-        });
+        var replicaShard = internalCluster().getInstance(IndicesService.class, replicaNodeName).getShardOrNull(shardId);
+        assertThat(replicaShard, notNullValue());
+        long expectedMaxSeqNo = totalDocs - 1 + nbGaps;
+        assertThat(replicaShard.withEngine(engine -> engine.getSeqNoStats(-1).getMaxSeqNo()), equalTo(expectedMaxSeqNo));
 
         // Stop the primary node: this triggers failover to the replica which will fill gaps in sequence numbers with NoOp tombstone
         // operations in IndexShard.updateShardState
