From df114184aa40db617cc51cfd939564c591f42e32 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C2=A8Claude?= <¨claude.warren@aiven.io¨>
Date: Thu, 2 Jan 2025 14:53:18 +0000
Subject: [PATCH] sped up integration test

---
 .../java/io/aiven/kafka/connect/s3/source/IntegrationBase.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/s3-source-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java b/s3-source-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
index e3fdc1f8..43851817 100644
--- a/s3-source-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
+++ b/s3-source-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
@@ -203,7 +203,7 @@ static <K, V> List<V> consumeMessages(final String topic, final int expectedMess
             consumer.subscribe(Collections.singletonList(topic));
 
             final List<V> recordValues = new ArrayList<>();
-            await().atMost(Duration.ofMinutes(5)).pollInterval(Duration.ofSeconds(5)).untilAsserted(() -> {
+            await().atMost(Duration.ofMinutes(1)).pollInterval(Duration.ofSeconds(5)).untilAsserted(() -> {
                 final ConsumerRecords<K, V> records = consumer.poll(Duration.ofMillis(500L));
                 for (final ConsumerRecord<K, V> record : records) {
                     recordValues.add(record.value());