lingwei.kong/hawkbit
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Add debug log to flaky RolloutManagementFlowTest (#1569)

Browse Source 
Signed-off-by: Marinov Avgustin <Avgustin.Marinov@bosch.com>
This commit is contained in:
Avgustin Marinov
2024-01-27 16:08:04 +02:00
committed by GitHub
parent cbc2185561
commit 5592689b62
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
hawkbit-repository/hawkbit-repository-jpa/src/test/java/org/eclipse/hawkbit/repository/jpa/management/RolloutManagementFlowTest.java
View File

@@ -78,7 +78,11 @@ class RolloutManagementFlowTest extends AbstractJpaIntegrationTest {
.filter(action -> !(targetPrefix + (amountGroups * 3 - 1)).equals(action.getTarget().getControllerId())) .filter(action -> !(targetPrefix + (amountGroups * 3 - 1)).equals(action.getTarget().getControllerId()))
.forEach(this::finishAction); .forEach(this::finishAction);
rolloutHandler.handleAll(); rolloutHandler.handleAll();
assertThat(refresh(groups.get(i)).getStatus()).isEqualTo(i + 1 == amountGroups ? RolloutGroupStatus.RUNNING : RolloutGroupStatus.FINISHED); final RolloutGroupStatus expectedStatus =
i + 1 == amountGroups ? RolloutGroupStatus.RUNNING : RolloutGroupStatus.FINISHED;
assertThat(refresh(groups.get(i)).getStatus())
.as("Check that group %s is in status %s", i, expectedStatus)
.isEqualTo(expectedStatus);
if (i + 1 != amountGroups) { if (i + 1 != amountGroups) {
assertThat(refresh(groups.get(i + 1)).getStatus()).isEqualTo(RolloutGroupStatus.RUNNING); assertThat(refresh(groups.get(i + 1)).getStatus()).isEqualTo(RolloutGroupStatus.RUNNING);
} }
@@ -141,7 +145,11 @@ class RolloutManagementFlowTest extends AbstractJpaIntegrationTest {
.filter(action -> !(targetPrefix + (amountGroups * 3 - 1)).equals(action.getTarget().getControllerId())) .filter(action -> !(targetPrefix + (amountGroups * 3 - 1)).equals(action.getTarget().getControllerId()))
.forEach(this::finishAction); .forEach(this::finishAction);
rolloutHandler.handleAll(); rolloutHandler.handleAll();
assertThat(refresh(groups.get(i)).getStatus()).isEqualTo(i + 1 == amountGroups ? RolloutGroupStatus.RUNNING : RolloutGroupStatus.FINISHED); final RolloutGroupStatus expectedStatus =
i + 1 == amountGroups ? RolloutGroupStatus.RUNNING : RolloutGroupStatus.FINISHED;
assertThat(refresh(groups.get(i)).getStatus())
.as("Check that group %s is in status %s", i, expectedStatus)
.isEqualTo(expectedStatus);
assertThat(refresh(i + 1 == amountGroups ? dynamic1 : groups.get(i + 1)).getStatus()).isEqualTo(RolloutGroupStatus.RUNNING); // on last round check dynamic assertThat(refresh(i + 1 == amountGroups ? dynamic1 : groups.get(i + 1)).getStatus()).isEqualTo(RolloutGroupStatus.RUNNING); // on last round check dynamic
} }