diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java index 11896d761..2bb8d9537 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java @@ -784,7 +784,7 @@ public class JpaRolloutExecutor implements RolloutExecutor { private int createActionsForDynamicGroupInNewTransaction(final JpaRollout rollout, final RolloutGroup group, final String targetFilter, final long limit) { - final List newActions = DeploymentHelper.runInNewTransaction(txManager, "createActionsForRolloutDynamicGroup", status -> { + return DeploymentHelper.runInNewTransaction(txManager, "createActionsForRolloutDynamicGroup", status -> { final PageRequest pageRequest = PageRequest.of(0, Math.toIntExact(limit)); final Slice targets = targetManagement.findByNotInGEGroupAndNotInActiveActionGEWeightOrInRolloutAndTargetFilterQueryAndCompatibleAndUpdatable( pageRequest, @@ -793,20 +793,19 @@ public class JpaRolloutExecutor implements RolloutExecutor { targetFilter, rollout.getDistributionSet().getType()); if (targets.getNumberOfElements() == 0) { - return Collections.emptyList(); + return 0; } final DistributionSet distributionSet = rollout.getDistributionSet(); final ActionType actionType = rollout.getActionType(); final long forceTime = rollout.getForcedTime(); - return createActions(targets.getContent(), distributionSet, actionType, forceTime, rollout, group); + final List newActions = createActions(targets.getContent(), distributionSet, actionType, forceTime, rollout, group); + if (!newActions.isEmpty()) { + deploymentManagement.startScheduledActions(newActions); + } + + return newActions.size(); }); - - if (!newActions.isEmpty()) { - deploymentManagement.startScheduledActions(newActions); - } - - return newActions.size(); } /**