(nifi) branch main updated: NIFI-16289 Wait for Couchbase bucket readiness in integration tests (#11620)

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 10b129ff931 NIFI-16289 Wait for Couchbase bucket readiness in 
integration tests (#11620)
10b129ff931 is described below

commit 10b129ff931e079392ca9f899173fb64ab4ac001
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Thu Sep 3 12:46:21 2026 -0400

    NIFI-16289 Wait for Couchbase bucket readiness in integration tests (#11620)
---
 .../nifi/processors/couchbase/integration/AbstractCouchbaseIT.java      | 2 +-
 .../apache/nifi/processors/couchbase/integration/GetCouchbaseIT.java    | 1 +
 .../apache/nifi/processors/couchbase/integration/PutCouchbaseIT.java    | 1 +
 3 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
index 7dc4a35af96..dce81b88b87 100644
--- 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
+++ 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/AbstractCouchbaseIT.java
@@ -44,7 +44,7 @@ public class AbstractCouchbaseIT {
     protected static final String COUCHBASE_IMAGE_COMMUNITY_RECENT = 
"couchbase/server:community-7.6.2";
     protected static final String SERVICE_ID = "couchbaseConnectionService";
     protected static final String TEST_DOCUMENT_ID = "test-document-id";
-    private static final Duration CLIENT_READY_TIMEOUT = 
Duration.ofSeconds(60);
+    protected static final Duration CLIENT_READY_TIMEOUT = 
Duration.ofSeconds(60);
     private static final Duration CLIENT_READY_POLL_INTERVAL = 
Duration.ofMillis(100);
 
     protected static final String TEST_DATA = """
diff --git 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/GetCouchbaseIT.java
 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/GetCouchbaseIT.java
index 5836b85d403..1ce615e19dc 100644
--- 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/GetCouchbaseIT.java
+++ 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/GetCouchbaseIT.java
@@ -88,6 +88,7 @@ public class GetCouchbaseIT extends AbstractCouchbaseIT {
                 CONTAINER.getPassword()
         )) {
             final Bucket bucket = cluster.bucket(TEST_BUCKET_NAME);
+            bucket.waitUntilReady(CLIENT_READY_TIMEOUT);
             final Collection collection = bucket.defaultCollection();
 
             collection.upsert(TEST_DOCUMENT_ID, 
JsonObject.fromJson(TEST_DATA));
diff --git 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/PutCouchbaseIT.java
 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/PutCouchbaseIT.java
index a64919d17ca..b598cd9cf7d 100644
--- 
a/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/PutCouchbaseIT.java
+++ 
b/nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/integration/PutCouchbaseIT.java
@@ -87,6 +87,7 @@ public class PutCouchbaseIT extends AbstractCouchbaseIT {
                 CONTAINER.getPassword()
         )) {
             final Bucket bucket = cluster.bucket(TEST_BUCKET_NAME);
+            bucket.waitUntilReady(CLIENT_READY_TIMEOUT);
             final Collection collection = bucket.defaultCollection();
 
             final GetResult result = collection.get(TEST_DOCUMENT_ID);