Skip to content

Commit

Permalink
fix(tests): increase timeout on JdbcServiceLivenessCoordinatorTest.ta…
Browse files Browse the repository at this point in the history
…skResubmitSkipExecution
  • Loading branch information
brian-mulier-p committed Feb 18, 2025
1 parent 16e3830 commit cebe8f3
Showing 1 changed file with 3 additions and 10 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package io.kestra.jdbc.runner;

import com.google.common.collect.ImmutableMap;
import io.kestra.core.junit.annotations.KestraTest;
import io.kestra.core.models.conditions.ConditionContext;
import io.kestra.core.models.executions.Execution;
import io.kestra.core.models.executions.TaskRun;
Expand All @@ -11,14 +12,7 @@
import io.kestra.core.queues.QueueFactoryInterface;
import io.kestra.core.queues.QueueInterface;
import io.kestra.core.repositories.LocalFlowRepositoryLoader;
import io.kestra.core.runners.RunContextFactory;
import io.kestra.core.runners.StandAloneRunner;
import io.kestra.core.runners.Worker;
import io.kestra.core.runners.WorkerJob;
import io.kestra.core.runners.WorkerTask;
import io.kestra.core.runners.WorkerTaskResult;
import io.kestra.core.runners.WorkerTrigger;
import io.kestra.core.runners.WorkerTriggerResult;
import io.kestra.core.runners.*;
import io.kestra.core.services.SkipExecutionService;
import io.kestra.core.tasks.test.SleepTrigger;
import io.kestra.core.utils.Await;
Expand All @@ -28,7 +22,6 @@
import io.kestra.plugin.core.flow.Sleep;
import io.micronaut.context.ApplicationContext;
import io.micronaut.context.annotation.Property;
import io.kestra.core.junit.annotations.KestraTest;
import jakarta.inject.Inject;
import jakarta.inject.Named;
import org.junit.jupiter.api.BeforeAll;
Expand Down Expand Up @@ -157,7 +150,7 @@ void taskResubmitSkipExecution() throws Exception {
});

workerJobQueue.emit(workerTask);
boolean runningLatchAwait = runningLatch.await(2, TimeUnit.SECONDS);
boolean runningLatchAwait = runningLatch.await(10, TimeUnit.SECONDS);
assertThat(runningLatchAwait, is(true));
worker.shutdown();

Expand Down

0 comments on commit cebe8f3

Please sign in to comment.