diff --git a/src/test/java/com/clearfolio/viewer/service/DefaultConversionWorkerTest.java b/src/test/java/com/clearfolio/viewer/service/DefaultConversionWorkerTest.java index 88503b486..b1ce6950c 100644 --- a/src/test/java/com/clearfolio/viewer/service/DefaultConversionWorkerTest.java +++ b/src/test/java/com/clearfolio/viewer/service/DefaultConversionWorkerTest.java @@ -392,7 +392,10 @@ void workerReschedulesWhenRetryAtIsInTheFuture() throws Exception { worker.enqueue(jobId); - await(() -> attempts.get() >= 1, 3_000); + await( + () -> attempts.get() >= 1 && job.getStatus() == ConversionJobStatus.SUCCEEDED, + 3_000 + ); assertEquals(1, attempts.get()); assertEquals(1, job.getAttemptCount());