Add timeout for not found as during a replication pause it is normal …

…not to find the object Issue: ZENKO-4903
scality · Oct 4, 2024 · c6c9649 · c6c9649
1 parent a169989
commit c6c9649
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 7 deletions.
diff --git a/tests/ctst/steps/dr/drctl.ts b/tests/ctst/steps/dr/drctl.ts
@@ -169,10 +169,8 @@ type ReplicationResumeConfig = {
     sourceKubeconfigData?: string;
     sinkKubeconfigPath?: string;
     sinkKubeconfigData?: string;
-    sourceZenkoInstance?: string;
-    sourceZenkoNamespace?: string;
-    sinkZenkoInstance?: string;
-    sinkZenkoNamespace?: string;
+    sourceZenkoDrNamespace?: string;
+    sinkZenkoDrNamespace?: string;
     sourceZenkoDrInstance?: string;
     sinkZenkoDrInstance?: string;
     wait?: boolean;

diff --git a/tests/ctst/steps/pra.ts b/tests/ctst/steps/pra.ts
@@ -360,10 +360,10 @@ When('I resume the DR', { timeout: resumeTimeout + 2000 }, async function (this:
     await this.zenkoDrCtl?.replicationResume({
         sourceZenkoDrInstance: 'end2end-source',
         sinkZenkoDrInstance: 'end2end-pra-sink',
-        sinkZenkoNamespace: 'default',
-        sourceZenkoNamespace: 'default',
+        sinkZenkoDrNamespace: 'default',
+        sourceZenkoDrNamespace: 'default',
         wait: true,
-        timeout: `${resumeTimeout.toString()}ms`,
+        timeout: `${pauseTimeout.toString()}ms`,
     });
 });
 

diff --git a/tests/ctst/steps/utils/utils.ts b/tests/ctst/steps/utils/utils.ts
@@ -296,9 +296,15 @@ async function verifyObjectLocation(this: Zenko, objectName: string,
         this.addCommandParameter({ versionId });
     }
     let conditionOk = false;
+
+    const startTime = Date.now();
+
     while (!conditionOk) {
         const res = await S3.headObject(this.getCommandParameters());
         if (res.err?.includes('NotFound')) {
+            if (Date.now() - startTime > 300000) {
+                throw new Error('Object not found after 300 seconds');
+            }
             await Utils.sleep(1000);
             continue;
         } else if (res.err) {