From 61b55bd1a532707f5464c140c8e2796bf07cc7fc Mon Sep 17 00:00:00 2001 From: musketyr Date: Tue, 10 Dec 2024 09:53:58 +0100 Subject: [PATCH] increased polling time, starting container manually --- .../com/agorapulse/worker/redis/RedisJobExecutorSpec.groovy | 6 ++++-- .../worker/tck/executor/AbstractJobExecutorSpec.groovy | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/libs/micronaut-worker-executor-redis/src/test/groovy/com/agorapulse/worker/redis/RedisJobExecutorSpec.groovy b/libs/micronaut-worker-executor-redis/src/test/groovy/com/agorapulse/worker/redis/RedisJobExecutorSpec.groovy index 50d0540b..6bf07d8b 100644 --- a/libs/micronaut-worker-executor-redis/src/test/groovy/com/agorapulse/worker/redis/RedisJobExecutorSpec.groovy +++ b/libs/micronaut-worker-executor-redis/src/test/groovy/com/agorapulse/worker/redis/RedisJobExecutorSpec.groovy @@ -25,12 +25,10 @@ import com.agorapulse.worker.tck.executor.AbstractJobExecutorSpec import com.agorapulse.worker.tck.executor.JobExecutorEventCollector import io.micronaut.context.ApplicationContext import org.testcontainers.containers.GenericContainer -import org.testcontainers.spock.Testcontainers import spock.lang.Retry import spock.lang.Shared @Retry(delay = 500) -@Testcontainers class RedisJobExecutorSpec extends AbstractJobExecutorSpec { @Shared @@ -41,6 +39,10 @@ class RedisJobExecutorSpec extends AbstractJobExecutorSpec { @SuppressWarnings('FactoryMethodName') protected ApplicationContext buildContext(JobQueues queues) { + if (!redis.running) { + redis.start() + } + ApplicationContext ctx = ApplicationContext .builder( 'redis.uri': "redis://$redis.host:${redis.getMappedPort(6379)}", diff --git a/libs/micronaut-worker-tck/src/main/groovy/com/agorapulse/worker/tck/executor/AbstractJobExecutorSpec.groovy b/libs/micronaut-worker-tck/src/main/groovy/com/agorapulse/worker/tck/executor/AbstractJobExecutorSpec.groovy index 292f4be0..fa763ae8 100644 --- a/libs/micronaut-worker-tck/src/main/groovy/com/agorapulse/worker/tck/executor/AbstractJobExecutorSpec.groovy +++ b/libs/micronaut-worker-tck/src/main/groovy/com/agorapulse/worker/tck/executor/AbstractJobExecutorSpec.groovy @@ -35,7 +35,7 @@ abstract class AbstractJobExecutorSpec extends Specification { public static final long LONG_RUNNING_JOB_DURATION = 500 private final PollingConditions conditions = new PollingConditions( - timeout: 30, + timeout: 60, initialDelay: 5 )