Browse Source
Merge pull request #13609 from thingsboard/fix/flaky-tests
Fix some flaky tests
pull/13606/head
Viacheslav Klimov
12 months ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with
2 additions and
2 deletions
-
application/src/test/java/org/thingsboard/server/service/job/JobManagerTest.java
-
application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
|
|
|
@ -165,7 +165,7 @@ public class JobManagerTest extends AbstractControllerTest { |
|
|
|
await().atMost(TIMEOUT, TimeUnit.SECONDS).untilAsserted(() -> { |
|
|
|
Job job = findJobById(jobId); |
|
|
|
assertThat(job.getStatus()).isEqualTo(JobStatus.CANCELLED); |
|
|
|
assertThat(job.getResult().getDiscardedCount()).isBetween(1, tasksCount - 1); |
|
|
|
assertThat(job.getResult().getDiscardedCount()).isBetween(1, tasksCount); |
|
|
|
assertThat(job.getResult().getTotalCount()).isEqualTo(tasksCount); |
|
|
|
assertThat(job.getResult().getCompletedCount()).isEqualTo(tasksCount); |
|
|
|
}); |
|
|
|
|
|
|
|
@ -467,7 +467,7 @@ public class TbRuleEngineQueueConsumerManagerTest { |
|
|
|
|
|
|
|
consumerManager.delete(true); |
|
|
|
|
|
|
|
await().atMost(2, TimeUnit.SECONDS) |
|
|
|
await().atMost(5, TimeUnit.SECONDS) |
|
|
|
.untilAsserted(() -> { |
|
|
|
verify(ruleEngineMsgProducer).send(any(), any(), any()); |
|
|
|
}); |
|
|
|
|