handle error when iterating over active rollouts! (#1747)

* handle error when iterating over active rollouts!

Signed-off-by: TRS1SF3 <Stanislav.Trailov@bosch.io>

* fix typo and message

Signed-off-by: TRS1SF3 <Stanislav.Trailov@bosch.io>

---------

Signed-off-by: TRS1SF3 <Stanislav.Trailov@bosch.io>
This commit is contained in:
Stanislav Trailov
2024-06-17 09:23:56 +03:00
committed by GitHub
parent 0916cc6960
commit b42765b4eb

View File

@@ -80,7 +80,12 @@ public class JpaRolloutHandler implements RolloutHandler {
try {
log.trace("Trigger handling {} rollouts.", rollouts.size());
rollouts.forEach(rolloutId -> handleRolloutInNewTransaction(rolloutId, handlerId));
rollouts.forEach(rolloutId -> {
try {
handleRolloutInNewTransaction(rolloutId, handlerId);
} catch (final Throwable throwable) {
log.error("Failed to process rollout with id {}", rolloutId , throwable);
}});
} finally {
if (log.isTraceEnabled()) {
log.trace("Unlock lock {}", lock);