fix: receive message wait time cannot be larger than 20

kestra-io · Jul 5, 2024 · 0847ab1 · 0847ab1
1 parent 6ef3f3e
commit 0847ab1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/kestra/plugin/aws/sqs/RealtimeTrigger.java b/src/main/java/io/kestra/plugin/aws/sqs/RealtimeTrigger.java
@@ -126,8 +126,8 @@ public Flux<Message> publisher(final Consume task,
                     while (isActive.get()) {
                         ReceiveMessageRequest receiveRequest = ReceiveMessageRequest.builder()
                             .queueUrl(queueUrl)
-                            // default read timeout is 30s, so we cannot use a bigger wait time, or we would need to increase the read timeout
-                            .waitTimeSeconds(30)
+                            // default read timeout is 20s, so we cannot use a bigger wait time, or we would need to increase the read timeout
+                            .waitTimeSeconds(20)
                             .build();
 
                         sqsClient.receiveMessage(receiveRequest)