diff --git a/src/vxingest/builder_common/ingest_manager.py b/src/vxingest/builder_common/ingest_manager.py
index 52554d7..6ce5a37 100644
--- a/src/vxingest/builder_common/ingest_manager.py
+++ b/src/vxingest/builder_common/ingest_manager.py
@@ -120,6 +120,7 @@ def connect_cb(self):
                     self.cluster = Cluster(
                         "couchbase://" + self.cb_credentials["host"], options
                     )
+                    break
                 except CouchbaseException as _e:
                     time.sleep(5)
                     _attempts = _attempts + 1