open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Retry opening couchbase 3.1 bucket (#12865)

This commit is contained in:
Lauri Tulmin 2024-12-09 17:42:42 +02:00 committed by GitHub
parent 265cbe47fb
commit 9cf097364c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
instrumentation/couchbase/couchbase-3.1/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/couchbase/v3_1/CouchbaseClient31Test.java
View File

@ -5,8 +5,11 @@
package io.opentelemetry.javaagent.instrumentation.couchbase.v3_1; package io.opentelemetry.javaagent.instrumentation.couchbase.v3_1;
import static org.awaitility.Awaitility.await;
import com.couchbase.client.core.env.TimeoutConfig; import com.couchbase.client.core.env.TimeoutConfig;
import com.couchbase.client.core.error.DocumentNotFoundException; import com.couchbase.client.core.error.DocumentNotFoundException;
import com.couchbase.client.core.error.UnambiguousTimeoutException;
import com.couchbase.client.java.Bucket; import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster; import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.ClusterOptions; import com.couchbase.client.java.ClusterOptions;
@ -62,11 +65,18 @@ class CouchbaseClient31Test {
ClusterOptions.clusterOptions(couchbase.getUsername(), couchbase.getPassword()) ClusterOptions.clusterOptions(couchbase.getUsername(), couchbase.getPassword())
.environment(environment)); .environment(environment));
Bucket bucket = cluster.bucket("test"); // wait and retry in the hope that it will help against test flakiness
collection = bucket.defaultCollection(); await()
.atMost(Duration.ofMinutes(2))
.ignoreException(UnambiguousTimeoutException.class)
.until(
() -> {
Bucket bucket = cluster.bucket("test");
collection = bucket.defaultCollection();
// Wait 1 minute due to slow startup contributing to flakiness bucket.waitUntilReady(Duration.ofSeconds(30));
bucket.waitUntilReady(Duration.ofMinutes(1)); return true;
});
} }
@AfterAll @AfterAll