diff --git a/server/build.gradle b/server/build.gradle index 38ebba808..aca956f76 100644 --- a/server/build.gradle +++ b/server/build.gradle @@ -16,19 +16,46 @@ plugins { } dependencies { - - implementation project(':conductor-rest') implementation project(':conductor-core') + implementation project(':conductor-rest') + implementation project(':conductor-grpc-server') + + //Event Systems + implementation project(':conductor-amqp') + implementation project(':conductor-nats') + implementation project(':conductor-nats-streaming') + implementation project(':conductor-awssqs-event-queue') + + //External Payload Storage + implementation project(':conductor-azureblob-storage') + implementation project(':conductor-postgres-external-storage') + implementation project(':conductor-awss3-storage') + + + //Persistence implementation project(':conductor-redis-persistence') implementation project(':conductor-cassandra-persistence') - implementation project(':conductor-es6-persistence') - implementation project(':conductor-grpc-server') + implementation project(':conductor-postgres-persistence') + implementation project(':conductor-mysql-persistence') + + //Indexing (note: Elasticsearch 6 is deprecated) + implementation project(':conductor-es7-persistence') + + implementation project(':conductor-redis-lock') implementation project(':conductor-redis-concurrency-limit') + + //System Tasks implementation project(':conductor-http-task') implementation project(':conductor-json-jq-task') - implementation project(':conductor-awss3-storage') - implementation project(':conductor-awssqs-event-queue') + implementation project(':conductor-kafka') + + //Metrics + implementation project(':conductor-metrics') + + //Event Listener + implementation project(':conductor-workflow-event-listener') + implementation 'org.springframework.boot:spring-boot-starter' implementation 'org.springframework.boot:spring-boot-starter-validation' diff --git a/workflow-event-listener/build.gradle b/workflow-event-listener/build.gradle index 840bff300..b30e145ee 100644 --- a/workflow-event-listener/build.gradle +++ b/workflow-event-listener/build.gradle @@ -5,19 +5,19 @@ dependencies { implementation project(':conductor-common') implementation project(':conductor-core') + implementation project(':conductor-redis-persistence') compileOnly 'org.springframework.boot:spring-boot-starter' compileOnly 'org.springframework.boot:spring-boot-starter-web' + testImplementation project(':conductor-server') testImplementation "org.apache.groovy:groovy-all:${revGroovy}" testImplementation "org.spockframework:spock-core:${revSpock}" testImplementation "org.spockframework:spock-spring:${revSpock}" - implementation "org.springframework.boot:spring-boot-starter-log4j2" - - - implementation project(':conductor-server') + testImplementation 'org.springframework.retry:spring-retry' testImplementation 'org.springframework.boot:spring-boot-starter-web' + testImplementation "com.netflix.dyno-queues:dyno-queues-redis:${revDynoQueues}" testImplementation project(':conductor-test-util').sourceSets.test.output //In memory diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWithTTLWorkflowStatusListener.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWithTTLWorkflowStatusListener.java index 12ac5d268..cc58948c1 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWithTTLWorkflowStatusListener.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWithTTLWorkflowStatusListener.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at @@ -14,8 +15,6 @@ import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; - -import jakarta.annotation.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -24,6 +23,8 @@ import com.netflix.conductor.metrics.Monitors; import com.netflix.conductor.model.WorkflowModel; +import jakarta.annotation.*; + public class ArchivingWithTTLWorkflowStatusListener implements WorkflowStatusListener { private static final Logger LOGGER = diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerConfiguration.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerConfiguration.java index b6de249cb..50978417d 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerConfiguration.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerConfiguration.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerProperties.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerProperties.java index f687516f3..53361429a 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerProperties.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowListenerProperties.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowStatusListener.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowStatusListener.java index 9016d33f4..c784c38a4 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowStatusListener.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/archive/ArchivingWorkflowStatusListener.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisher.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisher.java index 75b3166a3..d10bf5f73 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisher.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisher.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherConfiguration.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherConfiguration.java index 83a32fe10..8cdf76f14 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherConfiguration.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherConfiguration.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherProperties.java b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherProperties.java index 522279385..4073ce7ad 100644 --- a/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherProperties.java +++ b/workflow-event-listener/src/main/java/com/netflix/conductor/contribs/listener/conductorqueue/ConductorQueueStatusPublisherProperties.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/test/java/com/netflix/conductor/contribs/listener/ArchivingWorkflowStatusListenerTest.java b/workflow-event-listener/src/test/java/com/netflix/conductor/contribs/listener/ArchivingWorkflowStatusListenerTest.java index 65372ac86..7532fb01d 100644 --- a/workflow-event-listener/src/test/java/com/netflix/conductor/contribs/listener/ArchivingWorkflowStatusListenerTest.java +++ b/workflow-event-listener/src/test/java/com/netflix/conductor/contribs/listener/ArchivingWorkflowStatusListenerTest.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at diff --git a/workflow-event-listener/src/test/java/com/netflix/conductor/test/listener/WorkflowStatusPublisherIntegrationTest.java b/workflow-event-listener/src/test/java/com/netflix/conductor/test/listener/WorkflowStatusPublisherIntegrationTest.java index 86fc0017c..4f9f002b6 100644 --- a/workflow-event-listener/src/test/java/com/netflix/conductor/test/listener/WorkflowStatusPublisherIntegrationTest.java +++ b/workflow-event-listener/src/test/java/com/netflix/conductor/test/listener/WorkflowStatusPublisherIntegrationTest.java @@ -1,4 +1,5 @@ /* + * Copyright 2023 Netflix, Inc. *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at @@ -51,6 +52,7 @@ @RunWith(SpringRunner.class) @SpringBootTest( properties = { + "conductor.db.type=memory", "conductor.workflow-status-listener.type=queue_publisher", "conductor.workflow-status-listener.queue-publisher.successQueue=dummy", "conductor.workflow-status-listener.queue-publisher.failureQueue=dummy",