adaptive retries

Author: nammn

docker/mongodb-kubernetes-tests/kubetester/mongotester.py

@@ -195,7 +195,15 @@ def assert_scram_sha_authentication(
             except OperationFailure as e:
                 if i == 0:
                     fail(f"unable to authenticate after {attempts} attempts with error: {e}")
-                time.sleep(5)
+
+                # Use adaptive retry delays for better password propagation handling
+                remaining_attempts = i
+                if remaining_attempts >= attempts * 0.7:  # First ~30% of attempts
+                    delay = 10  # Longer delay for initial propagation
+                else:
+                    delay = 5   # Standard delay for normal retries
+
+                time.sleep(delay)
 
     def assert_scram_sha_authentication_fails(
         self,
@@ -239,7 +247,7 @@ def _authenticate_with_scram(
         # authentication doesn't actually happen until we interact with a database
         self.client["admin"]["myCol"].insert_one({})
 
-    def assert_x509_authentication(self, cert_file_name: str, attempts: int = 20, **kwargs):
+    def assert_x509_authentication(self, cert_file_name: str, attempts: int = 30, **kwargs):
         assert attempts > 0
 
         options = self._merge_options(
@@ -258,7 +266,15 @@ def assert_x509_authentication(self, cert_file_name: str, attempts: int = 20, **
             except OperationFailure:
                 if attempts == 0:
                     fail(f"unable to authenticate after {total_attempts} attempts")
-                time.sleep(5)
+
+                # Use adaptive retry delays for better credential propagation handling
+                remaining_attempts = attempts
+                if remaining_attempts >= total_attempts * 0.7:  # First ~30% of attempts
+                    delay = 10  # Longer delay for initial propagation
+                else:
+                    delay = 5   # Standard delay for normal retries
+
+                time.sleep(delay)
 
     def assert_ldap_authentication(
         self,
@@ -290,7 +306,15 @@ def assert_ldap_authentication(
             except OperationFailure:
                 if attempts <= 0:
                     fail(f"unable to authenticate after {total_attempts} attempts")
-                time.sleep(5)
+
+                # Use adaptive retry delays for better credential propagation handling
+                remaining_attempts = attempts
+                if remaining_attempts >= total_attempts * 0.7:  # First ~30% of attempts
+                    delay = 10  # Longer delay for initial propagation
+                else:
+                    delay = 5   # Standard delay for normal retries
+
+                time.sleep(delay)
 
     def assert_oidc_authentication(
         self,
@@ -317,7 +341,15 @@ def assert_oidc_authentication(
             except OperationFailure as e:
                 if attempts == 0:
                     raise RuntimeError(f"Unable to authenticate after {total_attempts} attempts: {e}")
-                time.sleep(5)
+
+                # Use adaptive retry delays for better credential propagation handling
+                remaining_attempts = attempts
+                if remaining_attempts >= total_attempts * 0.7:  # First ~30% of attempts
+                    delay = 10  # Longer delay for initial propagation
+                else:
+                    delay = 5   # Standard delay for normal retries
+
+                time.sleep(delay)
 
     def assert_oidc_authentication_fails(self, db: str = "admin", collection: str = "myCol", attempts: int = 10):
         assert attempts > 0