diff options
Diffstat (limited to 'clustercontroller-reindexer/src/test')
-rw-r--r-- | clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java index 8cf96fa8c45..cd9cf9f845d 100644 --- a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java +++ b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java @@ -91,9 +91,9 @@ class ReindexerTest { @Test @Timeout(10) void testReindexing() throws ReindexingLockException { - // Reindexer is created without any ready document types, which means nothing should run. - new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex(); - Reindexing reindexing = Reindexing.empty(); + // Reindexer is created against en empty database, so any ready document types are assumed already done. + new Reindexer(cluster, Map.of(music, Instant.ofEpochMilli(-10)), database, ReindexerTest::failIfCalled, metric, clock).reindex(); + Reindexing reindexing = Reindexing.empty().with(music, Status.ready(Instant.EPOCH).running().successful(Instant.EPOCH)); assertEquals(reindexing, database.readReindexing("cluster")); // New config tells reindexer to reindex "music" documents no earlier than at 10 millis after EPOCH, which isn't yet. @@ -156,6 +156,10 @@ class ReindexerTest { "clusterid", "cluster", "state", "pending"))); + // Reindexer is created without any ready document types, which means nothing should run. + new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex(); + assertEquals(reindexing, database.readReindexing("cluster")); + // Last reindexing fails. clock.advance(Duration.ofMillis(10)); shutDown.set(false); |