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
 
diff --git a/mock/mock.go b/mock/mock.go
index c7d5529..1dfc3a4 100644
--- a/mock/mock.go
+++ b/mock/mock.go
@@ -1229,6 +1229,7 @@ func handleSGRDFAction(w http.ResponseWriter, r *http.Request) {
 	PerformActionOnRDFSG(w, rdfNo, action)
 }
 
+// PerformActionOnRDFSG updates rdfNo with given action
 func PerformActionOnRDFSG(w http.ResponseWriter, rdfNo, action string) {
 	mockCacheMutex.Lock()
 	defer mockCacheMutex.Unlock()