Compare commits

...

1 Commits

Author SHA1 Message Date
Loïc Mathieu
cc812dc247 chore(deps): upgrade to Micronaut Platform 4.9.0
Closes #9848
2025-07-03 15:38:22 +02:00
3 changed files with 9 additions and 6 deletions

View File

@@ -65,4 +65,9 @@ public @interface Retryable {
* (defaults to none)
*/
Class<? extends RetryPredicate> predicate() default DefaultRetryPredicate.class;
/**
* @return The multiplier to use to calculate the delay
*/
String jitter() default "${kestra.retries.jitter:0.0}";
}

View File

@@ -18,10 +18,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.time.Duration;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Optional;
import java.util.*;
/**
* Replace {@link DefaultRetryInterceptor} only to catch Throwable
@@ -56,7 +53,8 @@ public class OverrideRetryInterceptor implements MethodInterceptor<Object, Objec
retry.get("delay", Duration.class).orElse(Duration.ofSeconds(1)),
retry.get("maxDelay", Duration.class).orElse(null),
new DefaultRetryPredicate(resolveIncludes(retry, "includes"), resolveIncludes(retry, "excludes")),
Throwable.class
Throwable.class,
retry.get("jitter", Double.class).orElse(0D)
);
MutableConvertibleValues<Object> attrs = context.getAttributes();

View File

@@ -26,7 +26,7 @@ dependencies {
// as Jackson is in the Micronaut BOM, to force its version we need to use enforcedPlatform but it didn't really work, see later :(
api enforcedPlatform("com.fasterxml.jackson:jackson-bom:$jacksonVersion")
api enforcedPlatform("org.slf4j:slf4j-api:$slf4jVersion")
api platform("io.micronaut.platform:micronaut-platform:4.8.2")
api platform("io.micronaut.platform:micronaut-platform:4.9.0")
api platform("io.qameta.allure:allure-bom:2.29.1")
// we define cloud bom here for GCP, Azure and AWS so they are aligned for all plugins that use them (secret, storage, oss and ee plugins)
api platform('com.google.cloud:libraries-bom:26.63.0')