diff --git a/inttest/pmax_replication_integration_test.go b/inttest/pmax_replication_integration_test.go
index 3e66446..146e63e 100644
--- a/inttest/pmax_replication_integration_test.go
+++ b/inttest/pmax_replication_integration_test.go
@@ -723,20 +723,24 @@ func TestExecuteReplicationActionOnSG(t *testing.T) {
 	}
 	fmt.Printf("Volume in Protected Storage Group created successfully: %v\n", vol)
 
-	fmt.Printf("Waiting for 10 minutes \n")
-	time.Sleep(600 * time.Second)
+	fmt.Printf("Waiting for 2 minutes \n")
+	time.Sleep(120 * time.Second)
 
 	err = client.ExecuteReplicationActionOnSG(context.TODO(), symmetrixID, "Suspend", defaultProtectedStorageGroup, localRDFGrpNo, true, true, false)
 	if err != nil {
 		t.Errorf("Error in suspending the RDF relation in Protected Storage Group: %s", err.Error())
 		return
 	}
+	fmt.Printf("Waiting for 2 minutes \n")
+	time.Sleep(120 * time.Second)
 
 	err = client.ExecuteReplicationActionOnSG(context.TODO(), symmetrixID, "Resume", defaultProtectedStorageGroup, localRDFGrpNo, true, true, false)
 	if err != nil {
 		t.Errorf("Error in resuming the RDF relation in Protected Storage Group: %s", err.Error())
 		return
 	}
+	fmt.Printf("Waiting for 2 minutes \n")
+	time.Sleep(120 * time.Second)
 
 	cleanupRDFPair(vol.VolumeID, volumeName, defaultProtectedStorageGroup, t)
 }
@@ -884,6 +888,9 @@ func cleanupRDFPair(volumeID string, _ string, _ string, t *testing.T) {
 		t.Errorf("Error retrieving RDF device pair information: %s", err.Error())
 		return
 	}
+	fmt.Printf("RDF INFO %v", rdfPair)
+	fmt.Printf("Waiting for 2 minutes \n")
+	time.Sleep(120 * time.Second)
 
 	// Terminating the Pair and removing the volumes from local SG and remote SG