From c6f90fac8738208497b2611c6fe7b4592f46ef12 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 14 Mar 2023 20:47:21 -0400 Subject: [PATCH] Some tweaks to leader election test --- .../aws/leader/DynamoDbLockRegistryLeaderInitiatorTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/org/springframework/integration/aws/leader/DynamoDbLockRegistryLeaderInitiatorTests.java b/src/test/java/org/springframework/integration/aws/leader/DynamoDbLockRegistryLeaderInitiatorTests.java index b4e8abd..fdc0b1d 100644 --- a/src/test/java/org/springframework/integration/aws/leader/DynamoDbLockRegistryLeaderInitiatorTests.java +++ b/src/test/java/org/springframework/integration/aws/leader/DynamoDbLockRegistryLeaderInitiatorTests.java @@ -82,7 +82,7 @@ class DynamoDbLockRegistryLeaderInitiatorTests implements LocalstackContainerTes List initiators = new ArrayList<>(); for (int i = 0; i < 2; i++) { DynamoDbLockRepository dynamoDbLockRepository = new DynamoDbLockRepository(DYNAMO_DB); - dynamoDbLockRepository.setLeaseDuration(Duration.ofSeconds(1)); + dynamoDbLockRepository.setLeaseDuration(Duration.ofSeconds(2)); dynamoDbLockRepository.afterPropertiesSet(); repositories.add(dynamoDbLockRepository); DynamoDbLockRegistry lockRepository = new DynamoDbLockRegistry(dynamoDbLockRepository); @@ -161,7 +161,7 @@ class DynamoDbLockRegistryLeaderInitiatorTests implements LocalstackContainerTes initiator1.getContext().yield(); - assertThat(revoked11.await(20, TimeUnit.SECONDS)).isTrue(); + assertThat(revoked11.await(30, TimeUnit.SECONDS)).isTrue(); assertThat(initiator1.getContext().isLeader()).isFalse(); initiator1.stop();