[DR] OPSAPS-35892 cm_api changes for HDFS Cloud replication schedule args

o Cloud HDFS Replication now has two for cloud accounts.
o user is expected to use one of them for given schedule.
o Unit test case changes.

Author: Nachiket Vaidya

python/src/cm_api/endpoints/types.py

@@ -713,8 +713,8 @@ class ApiHdfsCloudReplicationArguments(ApiHdfsReplicationArguments):
   def _get_attributes(cls):
     if not cls.__dict__.has_key('_ATTRIBUTES'):
       attrs = {
-        'cloudAccount'  : None,
-        'cloudService'    : None,
+        'sourceAccount' : None,
+        'destinationAccount' : None,
       }
       attrs.update(ApiHdfsReplicationArguments._get_attributes())
       cls._ATTRIBUTES = attrs

python/src/cm_api_tests/test_replication.py

@@ -96,8 +96,7 @@ def test_hdfs_cloud_arguments(self):
       "bandwidthPerMap" : "20",
       "preserveXAttrs" : false,
       "exclusionFilters" : ["ac"],
-      "cloudAccount" : "someTestAccount",
-      "cloudService" : "TARGET"
+      "sourceAccount" : "someTestAccount"
     }'''
     args = utils.deserialize(RAW, ApiHdfsCloudReplicationArguments)
     self.assertEquals('vst2', args.sourceService.peerName)
@@ -117,8 +116,8 @@ def test_hdfs_cloud_arguments(self):
     self.assertFalse(args.skipTrash)
     self.assertEquals('DYNAMIC', args.replicationStrategy)
     self.assertFalse(args.preserveXAttrs)
-    self.assertEquals('someTestAccount', args.cloudAccount)
-    self.assertEquals('TARGET', args.cloudService)
+    self.assertEquals('someTestAccount', args.sourceAccount)
+    self.assertEquals(None, args.destinationAccount)
 
   def test_hive_arguments(self):
     RAW = '''{
@@ -388,8 +387,7 @@ def test_hdfs_cloud_replication_crud(self):
     hdfs_args.sourceService = ApiServiceRef('cluster2', 'hdfs2')
     hdfs_args.sourcePath = '/src'
     hdfs_args.destinationPath = 's3a://somebucket/dst'
-    hdfs_args.cloudAccount = 'someTestAccount'
-    hdfs_args.cloudService = 'TARGET'
+    hdfs_args.destinationAccount = 'someTestAccount'
 
     return_sched = ApiReplicationSchedule(self.resource,
         interval=2, intervalUnit='DAY')