mirror of
https://github.com/kestra-io/kestra.git
synced 2025-12-19 18:05:41 -05:00
chore(deps): update all java deps
This commit is contained in:
committed by
Ludovic DEHON
parent
25b0e5e188
commit
a19df970bf
34
build.gradle
34
build.gradle
@@ -3,25 +3,25 @@ plugins {
|
||||
id "java"
|
||||
id 'java-library'
|
||||
id "idea"
|
||||
id "com.github.johnrengelman.shadow" version "7.0.0"
|
||||
id "com.github.johnrengelman.shadow" version "7.1.1"
|
||||
id "application"
|
||||
|
||||
// test
|
||||
id 'com.adarshr.test-logger' version '3.0.0'
|
||||
id 'com.adarshr.test-logger' version '3.1.0'
|
||||
id 'org.gradle.test-retry' version '1.3.1'
|
||||
|
||||
// helper
|
||||
id "com.github.ben-manes.versions" version "0.39.0"
|
||||
|
||||
// front
|
||||
id 'org.siouan.frontend-jdk11' version '5.3.0' apply false
|
||||
id 'org.siouan.frontend-jdk11' version '6.0.0' apply false
|
||||
|
||||
// release
|
||||
id "io.github.gradle-nexus.publish-plugin" version "1.1.0"
|
||||
id 'net.researchgate.release' version '2.8.1'
|
||||
id "com.gorylenko.gradle-git-properties" version "2.3.1"
|
||||
id "com.gorylenko.gradle-git-properties" version "2.3.2"
|
||||
id 'signing'
|
||||
id 'ru.vyarus.pom' version '2.2.0' apply false
|
||||
id 'ru.vyarus.pom' version '2.2.1' apply false
|
||||
id 'ru.vyarus.github-info' version '1.3.0' apply false
|
||||
}
|
||||
|
||||
@@ -93,26 +93,27 @@ allprojects {
|
||||
implementation "io.micrometer:micrometer-core"
|
||||
implementation "io.micronaut.micrometer:micronaut-micrometer-registry-prometheus"
|
||||
api "io.micronaut:micronaut-http-client"
|
||||
api "io.micronaut.rxjava2:micronaut-rxjava2-http-client"
|
||||
|
||||
// logs
|
||||
implementation "org.slf4j:slf4j-api:1.7.30"
|
||||
implementation "ch.qos.logback:logback-classic:1.2.3"
|
||||
implementation group: 'org.apache.logging.log4j', name: 'log4j-to-slf4j', version: '2.14.1'
|
||||
implementation "org.slf4j:slf4j-api:1.7.32"
|
||||
implementation "ch.qos.logback:logback-classic:1.2.8"
|
||||
implementation group: 'org.apache.logging.log4j', name: 'log4j-to-slf4j', version: '2.16.0'
|
||||
implementation group: 'org.slf4j', name: 'jul-to-slf4j', version: '1.7.30'
|
||||
|
||||
// jackson
|
||||
implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.12.3'
|
||||
implementation group: 'com.fasterxml.jackson.dataformat', name: 'jackson-dataformat-yaml', version: '2.12.3'
|
||||
implementation group: 'com.fasterxml.jackson.module', name: 'jackson-module-parameter-names', version: '2.12.3'
|
||||
implementation group: 'com.fasterxml.jackson.datatype', name: 'jackson-datatype-guava', version: '2.12.3'
|
||||
implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.13.0'
|
||||
implementation group: 'com.fasterxml.jackson.dataformat', name: 'jackson-dataformat-yaml', version: '2.13.0'
|
||||
implementation group: 'com.fasterxml.jackson.module', name: 'jackson-module-parameter-names', version: '2.13.0'
|
||||
implementation group: 'com.fasterxml.jackson.datatype', name: 'jackson-datatype-guava', version: '2.13.0'
|
||||
|
||||
// kestra
|
||||
implementation group: 'com.devskiller.friendly-id', name: 'friendly-id', version: '1.1.0'
|
||||
implementation 'com.github.jknack:handlebars:4.2.0'
|
||||
implementation group: 'net.thisptr', name: 'jackson-jq', version: '1.0.0-preview.20210610'
|
||||
implementation 'com.github.jknack:handlebars:4.3.0'
|
||||
implementation group: 'net.thisptr', name: 'jackson-jq', version: '1.0.0-preview.20210928'
|
||||
|
||||
// exposed utils
|
||||
api group: 'com.google.guava', name: 'guava', version: '30.1.1-jre'
|
||||
api group: 'com.google.guava', name: 'guava', version: '31.0.1-jre'
|
||||
api group: 'commons-io', name: 'commons-io', version: '2.11.0'
|
||||
api group: 'org.apache.commons', name: 'commons-lang3', version: '3.12.0'
|
||||
api "io.swagger.core.v3:swagger-annotations"
|
||||
@@ -144,7 +145,7 @@ subprojects {
|
||||
// hamcrest
|
||||
testImplementation 'org.hamcrest:hamcrest:2.2'
|
||||
testImplementation 'org.hamcrest:hamcrest-library:2.2'
|
||||
testImplementation group: 'org.exparity', name: 'hamcrest-date', version: '2.0.7'
|
||||
testImplementation group: 'org.exparity', name: 'hamcrest-date', version: '2.0.8'
|
||||
}
|
||||
|
||||
test {
|
||||
@@ -218,6 +219,7 @@ shadowJar {
|
||||
|
||||
archiveClassifier.set(null)
|
||||
mergeServiceFiles()
|
||||
zip64 true
|
||||
}
|
||||
|
||||
/**********************************************************************************************************************\
|
||||
|
||||
@@ -5,6 +5,7 @@ import io.micronaut.http.MutableHttpRequest;
|
||||
import io.micronaut.http.client.netty.DefaultHttpClient;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.net.URISyntaxException;
|
||||
import java.net.URL;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
@@ -24,8 +25,8 @@ public abstract class AbstractApiCommand extends AbstractCommand {
|
||||
super(withServer);
|
||||
}
|
||||
|
||||
protected DefaultHttpClient client() {
|
||||
return new DefaultHttpClient(server);
|
||||
protected DefaultHttpClient client() throws URISyntaxException {
|
||||
return new DefaultHttpClient(server.toURI());
|
||||
}
|
||||
|
||||
protected <T> HttpRequest<T> requestOptions(MutableHttpRequest<T> request) {
|
||||
|
||||
@@ -25,7 +25,7 @@ import java.text.MessageFormat;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.Callable;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
mixinStandardHelpOptions = true
|
||||
|
||||
@@ -4,8 +4,8 @@ import io.micronaut.context.event.StartupEvent;
|
||||
import io.micronaut.runtime.event.annotation.EventListener;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
class VersionProvider implements CommandLine.IVersionProvider {
|
||||
private static io.kestra.core.utils.VersionProvider versionProvider;
|
||||
|
||||
@@ -13,7 +13,7 @@ import picocli.CommandLine;
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.StreamSupport;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "properties",
|
||||
|
||||
@@ -11,7 +11,7 @@ import lombok.extern.slf4j.Slf4j;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.nio.file.Path;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "dot",
|
||||
|
||||
@@ -23,7 +23,7 @@ import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.TimeoutException;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "test",
|
||||
|
||||
@@ -8,7 +8,7 @@ import io.kestra.core.serializers.YamlFlowParser;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.nio.file.Path;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
@CommandLine.Command(
|
||||
|
||||
@@ -16,7 +16,7 @@ import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
import static io.kestra.core.utils.Rethrow.throwFunction;
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.nio.file.Path;
|
||||
import java.nio.file.Paths;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "doc",
|
||||
|
||||
@@ -15,7 +15,7 @@ import java.nio.file.StandardCopyOption;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "install",
|
||||
|
||||
@@ -10,7 +10,7 @@ import io.kestra.core.utils.Await;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "executor",
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.kestra.core.utils.Await;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "indexer",
|
||||
|
||||
@@ -10,7 +10,7 @@ import io.kestra.core.utils.Await;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "scheduler",
|
||||
|
||||
@@ -16,7 +16,7 @@ import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.util.Map;
|
||||
import java.util.Optional;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "standalone",
|
||||
|
||||
@@ -9,7 +9,7 @@ import io.kestra.core.utils.Await;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "webserver",
|
||||
|
||||
@@ -10,7 +10,7 @@ import io.kestra.core.utils.Await;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "worker",
|
||||
|
||||
@@ -10,7 +10,7 @@ import picocli.CommandLine;
|
||||
import java.time.Duration;
|
||||
import java.time.ZonedDateTime;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "restore-flow-listeners",
|
||||
|
||||
@@ -6,7 +6,7 @@ import io.micronaut.context.ApplicationContext;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import picocli.CommandLine;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@CommandLine.Command(
|
||||
name = "restore-queue",
|
||||
|
||||
@@ -10,8 +10,8 @@ import lombok.extern.slf4j.Slf4j;
|
||||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static io.kestra.core.utils.Rethrow.throwConsumer;
|
||||
|
||||
|
||||
@@ -26,8 +26,8 @@ import org.eclipse.aether.transport.http.HttpTransporterFactory;
|
||||
import org.eclipse.aether.util.filter.DependencyFilterUtils;
|
||||
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.net.MalformedURLException;
|
||||
|
||||
@@ -17,8 +17,8 @@ import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Optional;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class RestoreQueueService {
|
||||
|
||||
@@ -13,38 +13,39 @@ processResources.dependsOn copyGradleProperties
|
||||
|
||||
dependencies {
|
||||
// log
|
||||
implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.2.3'
|
||||
implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.2.8'
|
||||
|
||||
// serializers
|
||||
implementation group: 'com.fasterxml.jackson.dataformat', name: 'jackson-dataformat-ion', version: '2.12.3'
|
||||
implementation group: 'com.fasterxml.jackson.dataformat', name: 'jackson-dataformat-ion', version: '2.13.0'
|
||||
|
||||
// utils
|
||||
implementation group: 'net.jodah', name: 'failsafe', version: '2.4.1'
|
||||
implementation 'com.github.oshi:oshi-core:5.7.3'
|
||||
implementation group: 'net.jodah', name: 'failsafe', version: '2.4.4'
|
||||
implementation 'com.github.oshi:oshi-core:5.8.6'
|
||||
implementation 'io.pebbletemplates:pebble:3.1.5'
|
||||
|
||||
// scheduler
|
||||
implementation group: 'com.cronutils', name: 'cron-utils', version: '9.1.5'
|
||||
implementation group: 'com.cronutils', name: 'cron-utils', version: '9.1.6'
|
||||
|
||||
// process
|
||||
implementation ('com.github.docker-java:docker-java:3.2.11') {
|
||||
implementation ('com.github.docker-java:docker-java:3.2.12') {
|
||||
exclude group: 'com.github.docker-java', module: 'docker-java-transport-jersey'
|
||||
}
|
||||
implementation 'com.github.docker-java:docker-java-transport-httpclient5:3.2.11'
|
||||
implementation 'com.github.docker-java:docker-java-transport-httpclient5:3.2.12'
|
||||
|
||||
// schema
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-generator', version: '4.18.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-javax-validation', version: '4.18.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-jackson', version: '4.18.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-swagger-2', version: '4.18.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-generator', version: '4.21.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-javax-validation', version: '4.21.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-jackson', version: '4.21.0'
|
||||
implementation group: 'com.github.victools', name: 'jsonschema-module-swagger-2', version: '4.21.0'
|
||||
|
||||
// test
|
||||
testImplementation project(':repository-memory')
|
||||
testImplementation project(':runner-memory')
|
||||
testImplementation project(':storage-local')
|
||||
|
||||
testImplementation 'org.mockito:mockito-junit-jupiter:3.11.2'
|
||||
testImplementation 'org.mockito:mockito-junit-jupiter:4.2.0'
|
||||
testImplementation "io.micronaut:micronaut-http-client"
|
||||
testImplementation "io.micronaut.rxjava2:micronaut-rxjava2-http-client"
|
||||
testImplementation "io.micronaut:micronaut-http-server-netty"
|
||||
testImplementation "io.micronaut:micronaut-management"
|
||||
}
|
||||
|
||||
@@ -4,14 +4,10 @@ import io.kestra.core.plugins.PluginRegistry;
|
||||
import io.micronaut.context.ApplicationContextConfiguration;
|
||||
import io.micronaut.context.DefaultApplicationContext;
|
||||
import io.micronaut.core.annotation.NonNull;
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import io.micronaut.core.io.service.ServiceDefinition;
|
||||
import io.micronaut.core.io.service.SoftServiceLoader;
|
||||
import io.micronaut.inject.BeanDefinitionReference;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.function.Predicate;
|
||||
|
||||
/**
|
||||
* Overload the {@link DefaultApplicationContext} in order to add plugins
|
||||
@@ -31,15 +27,15 @@ public class KestraApplicationContext extends DefaultApplicationContext {
|
||||
}
|
||||
|
||||
@Override
|
||||
protected @NonNull List<BeanDefinitionReference> resolveBeanDefinitionReferences(@Nullable Predicate<BeanDefinitionReference> predicate) {
|
||||
List<BeanDefinitionReference> resolvedBeanReferences = super.resolveBeanDefinitionReferences(predicate);
|
||||
protected @NonNull List<BeanDefinitionReference> resolveBeanDefinitionReferences() {
|
||||
List<BeanDefinitionReference> resolvedBeanReferences = super.resolveBeanDefinitionReferences();
|
||||
|
||||
if (pluginRegistry != null) {
|
||||
pluginRegistry
|
||||
.getPlugins()
|
||||
.forEach(plugin -> {
|
||||
final SoftServiceLoader<BeanDefinitionReference> definitions = SoftServiceLoader.load(BeanDefinitionReference.class, plugin.getClassLoader());
|
||||
definitions.collectAll(resolvedBeanReferences, reference -> reference.isPresent() && (predicate == null || predicate.test(reference)));
|
||||
definitions.collectAll(resolvedBeanReferences, BeanDefinitionReference::isPresent);
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -22,9 +22,9 @@ import java.util.*;
|
||||
*/
|
||||
public class KestraApplicationContextBuilder implements ApplicationContextConfiguration {
|
||||
private ClassLoader classLoader = getClass().getClassLoader();
|
||||
private List<String> environments = new ArrayList<>();
|
||||
private List<String> packages = new ArrayList<>();
|
||||
private Map<String, Object> properties = new LinkedHashMap<>();
|
||||
private final List<String> environments = new ArrayList<>();
|
||||
private final List<String> packages = new ArrayList<>();
|
||||
private final Map<String, Object> properties = new LinkedHashMap<>();
|
||||
private PluginRegistry pluginRegistry;
|
||||
|
||||
public KestraApplicationContextBuilder() {
|
||||
@@ -79,7 +79,6 @@ public class KestraApplicationContextBuilder implements ApplicationContextConfig
|
||||
return this;
|
||||
}
|
||||
|
||||
|
||||
@SuppressWarnings("MagicNumber")
|
||||
public @NonNull ApplicationContext build() {
|
||||
DefaultApplicationContext applicationContext = new KestraApplicationContext(this, this.pluginRegistry);
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
package io.kestra.core.contexts;
|
||||
|
||||
import edu.umd.cs.findbugs.annotations.NonNull;
|
||||
import edu.umd.cs.findbugs.annotations.Nullable;
|
||||
import io.micronaut.context.annotation.Replaces;
|
||||
import io.micronaut.core.annotation.NonNull;
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import io.micronaut.core.beans.BeanIntrospection;
|
||||
import io.micronaut.core.beans.BeanIntrospectionReference;
|
||||
import io.micronaut.core.beans.exceptions.IntrospectionException;
|
||||
@@ -30,7 +30,8 @@ public class KestraValidator extends DefaultValidator {
|
||||
super(configuration);
|
||||
}
|
||||
|
||||
protected @Nullable BeanIntrospection<Object> getBeanIntrospection(@NonNull Object object) {
|
||||
protected @Nullable
|
||||
BeanIntrospection<Object> getBeanIntrospection(@NonNull Object object) {
|
||||
//noinspection ConstantConditions
|
||||
if (object == null) {
|
||||
return null;
|
||||
|
||||
@@ -27,8 +27,8 @@ import java.util.*;
|
||||
import java.util.regex.Pattern;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class DocumentationGenerator {
|
||||
|
||||
@@ -25,7 +25,7 @@ import java.time.Duration;
|
||||
import java.util.*;
|
||||
import java.util.function.Predicate;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class JsonSchemaGenerator {
|
||||
|
||||
@@ -4,7 +4,7 @@ import io.micronaut.context.annotation.Requires;
|
||||
import io.micronaut.core.async.publisher.Publishers;
|
||||
import io.micronaut.http.*;
|
||||
import io.micronaut.http.annotation.Filter;
|
||||
import io.micronaut.http.filter.OncePerRequestHttpServerFilter;
|
||||
import io.micronaut.http.filter.HttpServerFilter;
|
||||
import io.micronaut.http.filter.ServerFilterChain;
|
||||
import io.micronaut.http.filter.ServerFilterPhase;
|
||||
import io.micronaut.inject.ExecutableMethod;
|
||||
@@ -20,7 +20,7 @@ import java.util.Optional;
|
||||
|
||||
@Filter("/**")
|
||||
@Requires(property = "endpoints.all.basic-auth")
|
||||
public class BasicAuthEndpointsFilter extends OncePerRequestHttpServerFilter {
|
||||
public class BasicAuthEndpointsFilter implements HttpServerFilter {
|
||||
private final EndpointBasicAuthConfiguration endpointBasicAuthConfiguration;
|
||||
|
||||
public BasicAuthEndpointsFilter(EndpointBasicAuthConfiguration endpointBasicAuthConfiguration) {
|
||||
@@ -29,7 +29,7 @@ public class BasicAuthEndpointsFilter extends OncePerRequestHttpServerFilter {
|
||||
|
||||
@SuppressWarnings("rawtypes")
|
||||
@Override
|
||||
protected Publisher<MutableHttpResponse<?>> doFilterOnce(HttpRequest<?> request, ServerFilterChain chain) {
|
||||
public Publisher<MutableHttpResponse<?>> doFilter(HttpRequest<?> request, ServerFilterChain chain) {
|
||||
Optional<RouteMatch> routeMatch = RouteMatchUtils.findRouteMatch(request);
|
||||
if (routeMatch.isPresent() && routeMatch.get() instanceof MethodBasedRouteMatch) {
|
||||
ExecutableMethod<?, ?> method = ((MethodBasedRouteMatch<?, ?>) routeMatch.get()).getExecutableMethod();
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.time.ZonedDateTime;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@Endpoint(id = "scheduler", defaultSensitive = false)
|
||||
@Requires(property = "kestra.server-type", pattern = "(SCHEDULER|STANDALONE)")
|
||||
|
||||
@@ -13,7 +13,7 @@ import io.kestra.core.runners.Worker;
|
||||
import java.util.List;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@Endpoint(id = "worker", defaultSensitive = false)
|
||||
@Requires(property = "kestra.server-type", pattern = "(WORKER|STANDALONE)")
|
||||
|
||||
@@ -3,6 +3,8 @@ package io.kestra.core.exceptions;
|
||||
import com.fasterxml.jackson.databind.exc.InvalidTypeIdException;
|
||||
|
||||
public class DeserializationException extends RuntimeException {
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
public DeserializationException(InvalidTypeIdException cause) {
|
||||
super(cause);
|
||||
}
|
||||
|
||||
@@ -4,7 +4,7 @@ import io.micronaut.retry.event.RetryEvent;
|
||||
import io.micronaut.runtime.event.annotation.EventListener;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Slf4j
|
||||
|
||||
@@ -6,8 +6,8 @@ import io.micronaut.context.annotation.Requires;
|
||||
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Requires(beans = MetricConfig.class)
|
||||
|
||||
@@ -12,8 +12,8 @@ import io.kestra.core.runners.WorkerTask;
|
||||
import io.kestra.core.runners.WorkerTaskResult;
|
||||
import io.kestra.core.schedulers.SchedulerExecutionWithTrigger;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Slf4j
|
||||
|
||||
@@ -4,8 +4,8 @@ import io.micronaut.validation.validator.Validator;
|
||||
|
||||
import java.util.Optional;
|
||||
import java.util.Set;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import javax.validation.ConstraintViolation;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
|
||||
@@ -6,7 +6,7 @@ import lombok.EqualsAndHashCode;
|
||||
import lombok.Getter;
|
||||
import lombok.ToString;
|
||||
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
import java.util.AbstractMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.kestra.core.runners.WorkerTask;
|
||||
import io.kestra.core.runners.WorkerTaskResult;
|
||||
import io.kestra.core.runners.WorkerTaskRunning;
|
||||
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class QueueService {
|
||||
|
||||
@@ -12,8 +12,8 @@ import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
@Singleton
|
||||
|
||||
@@ -12,9 +12,9 @@ import io.kestra.core.repositories.TriggerRepositoryInterface;
|
||||
import io.micronaut.context.annotation.Requires;
|
||||
|
||||
import java.io.IOException;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Requires(beans = {ExecutionRepositoryInterface.class, LogRepositoryInterface.class, TriggerRepositoryInterface.class})
|
||||
|
||||
@@ -10,8 +10,8 @@ import io.kestra.core.models.tasks.Task;
|
||||
import io.kestra.core.models.triggers.AbstractTrigger;
|
||||
|
||||
import java.util.Map;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class RunContextFactory {
|
||||
|
||||
@@ -34,9 +34,9 @@ import java.util.function.BiFunction;
|
||||
import java.util.function.Function;
|
||||
import java.util.function.Predicate;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class RunnerUtils {
|
||||
|
||||
@@ -12,8 +12,8 @@ import io.kestra.core.utils.ExecutorsUtils;
|
||||
import java.io.Closeable;
|
||||
import java.io.IOException;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
|
||||
@Slf4j
|
||||
public class StandAloneRunner implements RunnerInterface, Closeable {
|
||||
|
||||
@@ -23,8 +23,8 @@ import java.io.IOException;
|
||||
import java.io.StringWriter;
|
||||
import java.io.Writer;
|
||||
import java.util.*;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class VariableRenderer {
|
||||
|
||||
@@ -14,6 +14,7 @@ public class EvalHelper implements Helper<String> {
|
||||
this.variableRenderer = variableRenderer;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@SneakyThrows
|
||||
@Override
|
||||
public CharSequence apply(final String value, final Options options) {
|
||||
|
||||
@@ -20,6 +20,7 @@ public class FirstDefinedEvalHelper implements Helper<String> {
|
||||
this.variableRenderer = variableRenderer;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@SneakyThrows
|
||||
@Override
|
||||
public CharSequence apply(final String value, final Options options) {
|
||||
|
||||
@@ -17,7 +17,7 @@ import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static com.mitchellbosecke.pebble.operator.BinaryOperatorType.NORMAL;
|
||||
|
||||
|
||||
@@ -38,8 +38,8 @@ import java.util.concurrent.*;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Slf4j
|
||||
@Singleton
|
||||
|
||||
@@ -11,8 +11,8 @@ import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Slf4j
|
||||
@Singleton
|
||||
|
||||
@@ -9,7 +9,7 @@ import io.kestra.core.models.DeletedInterface;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
/*
|
||||
@Introspected
|
||||
@Singleton
|
||||
|
||||
@@ -9,9 +9,9 @@ import com.fasterxml.jackson.databind.deser.std.StringDeserializer;
|
||||
import com.fasterxml.jackson.databind.module.SimpleModule;
|
||||
import com.fasterxml.jackson.databind.ser.BeanSerializerModifier;
|
||||
import com.fasterxml.jackson.databind.type.TypeFactory;
|
||||
import edu.umd.cs.findbugs.annotations.Nullable;
|
||||
import io.kestra.core.contexts.KestraClassLoader;
|
||||
import io.micronaut.context.annotation.*;
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import io.micronaut.core.reflect.GenericTypeUtils;
|
||||
import io.micronaut.core.util.StringUtils;
|
||||
import io.micronaut.jackson.JacksonConfiguration;
|
||||
@@ -21,9 +21,9 @@ import java.text.SimpleDateFormat;
|
||||
import java.util.Locale;
|
||||
import java.util.Optional;
|
||||
import java.util.TimeZone;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
/**
|
||||
* hard copy from {link io.micronaut.jackson.{@link io.micronaut.jackson.ObjectMapperFactory}} just to change
|
||||
|
||||
@@ -16,8 +16,8 @@ import java.io.IOException;
|
||||
import java.nio.file.Path;
|
||||
import java.util.Collections;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
@Singleton
|
||||
|
||||
@@ -4,8 +4,8 @@ import io.micronaut.context.annotation.Requires;
|
||||
import io.micronaut.scheduling.annotation.Scheduled;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Slf4j
|
||||
|
||||
@@ -13,18 +13,18 @@ import io.micronaut.core.annotation.Nullable;
|
||||
import io.micronaut.core.type.Argument;
|
||||
import io.micronaut.http.HttpRequest;
|
||||
import io.micronaut.http.MutableHttpRequest;
|
||||
import io.micronaut.http.client.RxHttpClient;
|
||||
import io.micronaut.http.client.annotation.Client;
|
||||
import io.micronaut.http.client.exceptions.HttpClientResponseException;
|
||||
import io.micronaut.http.hateoas.JsonError;
|
||||
import io.micronaut.rxjava2.http.client.RxHttpClient;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import java.lang.management.ManagementFactory;
|
||||
import java.net.URI;
|
||||
import java.time.Instant;
|
||||
import java.time.ZoneId;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
@Slf4j
|
||||
|
||||
@@ -17,7 +17,7 @@ import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
/**
|
||||
* Provides business logic to manipulate {@link Condition}
|
||||
|
||||
@@ -15,8 +15,8 @@ import io.micronaut.core.annotation.Nullable;
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static io.kestra.core.utils.Rethrow.throwFunction;
|
||||
|
||||
|
||||
@@ -16,8 +16,8 @@ import io.kestra.core.utils.ListUtils;
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
/**
|
||||
* Provides business logic to manipulate {@link Flow}
|
||||
|
||||
@@ -8,8 +8,8 @@ import io.micronaut.context.ApplicationContext;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class PluginService {
|
||||
|
||||
@@ -15,9 +15,9 @@ import org.slf4j.Logger;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class TaskDefaultService {
|
||||
|
||||
@@ -7,7 +7,7 @@ import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
/**
|
||||
* Provides business logic to manipulate {@link WorkerInstance}
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
package io.kestra.core.tasks.debugs;
|
||||
|
||||
import io.micronaut.core.annotation.NonNull;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.*;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
@@ -35,8 +35,8 @@ import java.util.concurrent.atomic.AtomicReference;
|
||||
import java.util.function.BiFunction;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import javax.validation.Valid;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
|
||||
@@ -5,8 +5,8 @@ import io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics;
|
||||
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class ExecutorsUtils {
|
||||
|
||||
@@ -16,7 +16,7 @@ import java.util.List;
|
||||
import java.util.function.BiPredicate;
|
||||
import java.util.function.Predicate;
|
||||
import java.util.function.Supplier;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class RetryUtils {
|
||||
|
||||
@@ -3,8 +3,8 @@ package io.kestra.core.utils;
|
||||
import com.google.common.util.concurrent.ThreadFactoryBuilder;
|
||||
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class ThreadMainFactoryBuilder {
|
||||
|
||||
@@ -4,8 +4,8 @@ import io.micronaut.context.ApplicationContext;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import java.lang.Thread.UncaughtExceptionHandler;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Slf4j
|
||||
@Singleton
|
||||
|
||||
@@ -7,7 +7,7 @@ import io.kestra.core.models.flows.Flow;
|
||||
|
||||
import java.net.URI;
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class UriProvider {
|
||||
|
||||
@@ -9,8 +9,8 @@ import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.stream.Stream;
|
||||
import javax.annotation.PostConstruct;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Singleton
|
||||
public class VersionProvider {
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.micronaut.validation.validator.constraints.ConstraintValidator;
|
||||
import java.io.IOException;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
@Factory
|
||||
public class ValidationFactory {
|
||||
|
||||
@@ -13,7 +13,7 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -16,7 +16,7 @@ import java.nio.file.Paths;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.containsString;
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -7,9 +7,9 @@ import io.micronaut.http.HttpRequest;
|
||||
import io.micronaut.http.HttpResponse;
|
||||
import io.micronaut.http.HttpStatus;
|
||||
import io.micronaut.http.MutableHttpRequest;
|
||||
import io.micronaut.http.client.RxHttpClient;
|
||||
import io.micronaut.http.client.exceptions.HttpClientResponseException;
|
||||
import io.micronaut.runtime.server.EmbeddedServer;
|
||||
import io.micronaut.rxjava2.http.client.RxHttpClient;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
@@ -12,7 +12,7 @@ import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
||||
import java.time.ZonedDateTime;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.time.DayOfWeek;
|
||||
import java.time.LocalDate;
|
||||
import java.time.ZonedDateTime;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -13,7 +13,7 @@ import org.junit.jupiter.params.provider.MethodSource;
|
||||
import java.time.DayOfWeek;
|
||||
import java.time.LocalDate;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -8,7 +8,7 @@ import io.kestra.core.models.flows.Flow;
|
||||
import io.kestra.core.services.ConditionService;
|
||||
import io.kestra.core.utils.TestsUtils;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -8,7 +8,7 @@ import io.kestra.core.models.flows.Flow;
|
||||
import io.kestra.core.services.ConditionService;
|
||||
import io.kestra.core.utils.TestsUtils;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.kestra.core.utils.TestsUtils;
|
||||
|
||||
import java.util.Collections;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -13,7 +13,7 @@ import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.kestra.core.utils.TestsUtils;
|
||||
import io.kestra.runner.memory.MemoryMultipleConditionStorage;
|
||||
|
||||
import java.util.Collections;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -17,7 +17,7 @@ import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -16,7 +16,7 @@ import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -8,7 +8,7 @@ import io.kestra.core.models.flows.Flow;
|
||||
import io.kestra.core.services.ConditionService;
|
||||
import io.kestra.core.utils.TestsUtils;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.time.DayOfWeek;
|
||||
import java.time.LocalDate;
|
||||
import java.time.ZonedDateTime;
|
||||
import java.util.stream.Stream;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -11,7 +11,7 @@ import io.kestra.core.utils.TestsUtils;
|
||||
import java.io.File;
|
||||
import java.net.URL;
|
||||
import java.util.Optional;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
||||
@@ -14,7 +14,7 @@ import java.net.URL;
|
||||
import java.util.List;
|
||||
import java.util.concurrent.TimeoutException;
|
||||
import java.util.stream.Collectors;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -22,7 +22,7 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Optional;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -21,9 +21,9 @@ import io.kestra.core.tasks.scripts.Bash;
|
||||
import io.kestra.core.utils.IdUtils;
|
||||
import io.kestra.core.utils.TestsUtils;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
import java.io.IOException;
|
||||
import java.net.URISyntaxException;
|
||||
@@ -56,11 +56,11 @@ public abstract class AbstractFlowRepositoryTest {
|
||||
FlowListener.reset();
|
||||
}
|
||||
|
||||
private static Flow.FlowBuilder builder() {
|
||||
private static Flow.FlowBuilder<?, ?> builder() {
|
||||
return builder(IdUtils.create(), "test");
|
||||
}
|
||||
|
||||
private static Flow.FlowBuilder builder(String flowId, String taskId) {
|
||||
private static Flow.FlowBuilder<?, ?> builder(String flowId, String taskId) {
|
||||
return Flow.builder()
|
||||
.id(flowId)
|
||||
.namespace("io.kestra.unittest")
|
||||
@@ -295,6 +295,41 @@ public abstract class AbstractFlowRepositoryTest {
|
||||
assertThat(FlowListener.getEmits().stream().filter(r -> r.getType() == CrudEventType.DELETE).count(), is(1L));
|
||||
}
|
||||
|
||||
|
||||
@Test
|
||||
void removeTriggerDelete() throws InterruptedException {
|
||||
CountDownLatch countDownLatch = new CountDownLatch(1);
|
||||
|
||||
triggerQueue.receive(trigger -> {
|
||||
assertThat(trigger, is(nullValue()));
|
||||
countDownLatch.countDown();
|
||||
});
|
||||
|
||||
String flowId = IdUtils.create();
|
||||
|
||||
Flow flow = Flow.builder()
|
||||
.id(flowId)
|
||||
.namespace("io.kestra.unittest")
|
||||
.triggers(Collections.singletonList(AbstractSchedulerTest.UnitTest.builder()
|
||||
.id("sleep")
|
||||
.type(AbstractSchedulerTest.UnitTest.class.getName())
|
||||
.build()))
|
||||
.tasks(Collections.singletonList(Return.builder().id("test").type(Return.class.getName()).format("test").build()))
|
||||
.build();
|
||||
|
||||
Flow save = flowRepository.create(flow);
|
||||
|
||||
assertThat(flowRepository.findById(flow.getNamespace(), flow.getId()).isPresent(), is(true));
|
||||
|
||||
flowRepository.delete(save);
|
||||
countDownLatch.await();
|
||||
|
||||
assertThat(FlowListener.getEmits().size(), is(2));
|
||||
assertThat(FlowListener.getEmits().stream().filter(r -> r.getType() == CrudEventType.CREATE).count(), is(1L));
|
||||
assertThat(FlowListener.getEmits().stream().filter(r -> r.getType() == CrudEventType.DELETE).count(), is(1L));
|
||||
}
|
||||
|
||||
|
||||
@Singleton
|
||||
public static class FlowListener implements ApplicationEventListener<CrudEvent<Flow>> {
|
||||
private static List<CrudEvent<Flow>> emits = new ArrayList<>();
|
||||
|
||||
@@ -14,8 +14,8 @@ import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.Optional;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -7,7 +7,7 @@ import io.kestra.core.repositories.LocalFlowRepositoryLoader;
|
||||
import io.kestra.runner.memory.MemoryRunner;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
import java.io.IOException;
|
||||
import java.net.URISyntaxException;
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ import io.kestra.core.tasks.debugs.Return;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -13,7 +13,7 @@ import java.util.Collections;
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -10,9 +10,9 @@ import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.TimeoutException;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -2,7 +2,7 @@ package io.kestra.core.runners;
|
||||
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
public class FlowTriggerTest extends AbstractMemoryRunnerTest {
|
||||
@Inject
|
||||
|
||||
@@ -8,7 +8,7 @@ import io.kestra.core.models.flows.State;
|
||||
import io.kestra.core.repositories.FlowRepositoryInterface;
|
||||
import io.kestra.core.storages.StorageInterface;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@@ -14,9 +14,9 @@ import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.TimeoutException;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
||||
@@ -3,7 +3,7 @@ package io.kestra.core.runners;
|
||||
import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
@MicronautTest
|
||||
public class MultipleConditionTriggerTest extends AbstractMemoryRunnerTest {
|
||||
|
||||
@@ -11,9 +11,9 @@ import io.kestra.core.services.ExecutionService;
|
||||
|
||||
import java.time.Duration;
|
||||
import java.util.List;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import javax.inject.Singleton;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
import jakarta.inject.Singleton;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
@@ -2,7 +2,7 @@ package io.kestra.core.runners;
|
||||
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import jakarta.inject.Inject;
|
||||
|
||||
public class RestartTest extends AbstractMemoryRunnerTest {
|
||||
@Inject
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user