From 123b1cc890a6093893fdd7e69f590b42f210477c Mon Sep 17 00:00:00 2001 From: Trask Stalnaker Date: Mon, 11 Aug 2025 02:40:16 -0700 Subject: [PATCH] Increase timeout in opamp-client tests (#2079) --- .../client/internal/impl/OpampClientImplTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/opamp-client/src/test/java/io/opentelemetry/opamp/client/internal/impl/OpampClientImplTest.java b/opamp-client/src/test/java/io/opentelemetry/opamp/client/internal/impl/OpampClientImplTest.java index ec630dc7..db2780ed 100644 --- a/opamp-client/src/test/java/io/opentelemetry/opamp/client/internal/impl/OpampClientImplTest.java +++ b/opamp-client/src/test/java/io/opentelemetry/opamp/client/internal/impl/OpampClientImplTest.java @@ -209,7 +209,7 @@ class OpampClientImplTest { requestService.sendRequest(); // Await for onMessage call - await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onMessageCalls.get() == 1); + await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onMessageCalls.get() == 1); verify(callbacks).onMessage(MessageData.builder().setRemoteConfig(remoteConfig).build()); } @@ -267,7 +267,7 @@ class OpampClientImplTest { void onConnectionSuccessful_notifyCallback() { initializeClient(); - await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onConnectCalls.get() == 1); + await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onConnectCalls.get() == 1); verify(callbacks).onConnect(); verify(callbacks, never()).onConnectFailed(any()); @@ -311,7 +311,7 @@ class OpampClientImplTest { // Force request requestService.sendRequest(); - await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onErrorResponseCalls.get() == 1); + await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onErrorResponseCalls.get() == 1); verify(callbacks).onErrorResponse(errorResponse); verify(callbacks, never()).onMessage(any()); @@ -344,7 +344,7 @@ class OpampClientImplTest { enqueueServerToAgentResponse(response); requestService.sendRequest(); - await().atMost(Duration.ofSeconds(1)).until(() -> state.instanceUid.get() != initialUid); + await().atMost(Duration.ofSeconds(5)).until(() -> state.instanceUid.get() != initialUid); assertThat(state.instanceUid.get()).isEqualTo(serverProvidedUid); } @@ -359,7 +359,7 @@ class OpampClientImplTest { private RecordedRequest takeRequest() { try { - return server.takeRequest(1, TimeUnit.SECONDS); + return server.takeRequest(5, TimeUnit.SECONDS); } catch (InterruptedException e) { throw new RuntimeException(e); }