[recommission] OPSAPS-36382 Python API changes to support recommssion with start

Added to api endpoints hosts_recommission_with_start() and recommission_with_start()
for api_version >= 15.
These endpoints will start decommissioned roles before doing the recommission.

Author: Francis Pang

python/src/cm_api/endpoints/cms.py

@@ -245,6 +245,23 @@ def hosts_recommission(self, host_names):
     """
     return self._cmd('hostsRecommission', data=host_names)
 
+  def hosts_recommission_with_start(self, host_names):
+    """
+    Recommission the specified hosts by recommissioning the slave roles.
+    This command will start the roles before recommissioning.
+
+    Warning: Evolving. This method may change in the future and does not
+    offer standard compatibility guarantees.
+    Do not use without guidance from Cloudera.
+
+    Currently, only HDFS DataNodes will be started by this command.
+
+    @param host_names: List of names of hosts to be recommissioned.
+    @return: Information about the submitted command.
+    @since: API v15
+    """
+    return self._cmd('hostsRecommissionWithStart', data=host_names, api_version=15)
+
   def hosts_start_roles(self, host_names):
     """
     Start all the roles on the specified hosts.

python/src/cm_api/endpoints/services.py

@@ -849,6 +849,21 @@ def recommission(self, *role_names):
     """
     return self._cmd('recommission', data=role_names)
 
+  def recommission_with_start(self, *role_names):
+    """
+    Recommission roles in a service. Roles are started before recommissioning.
+
+    Warning: Evolving. This method may change in the future and does not offer
+    standard compatibility guarantees.
+    Only support by HDFS.
+    Do not use without guidance from Cloudera.
+
+    @param role_names: Names of the roles to recommission.
+    @return: Reference to the submitted command.
+    @since: API v15
+    """
+    return self._cmd('recommissionWithStart', data=role_names, api_version=15)
+
   def deploy_client_config(self, *role_names):
     """
     Deploys client configuration to the hosts where roles are running.

python/src/cm_api_tests/test_cms.py

@@ -128,6 +128,20 @@ def test_host_commission(self):
         retdata={})
     cms.hosts_recommission([ "host1", "host2" ])
 
+  def test_host_commission_with_start(self):
+    resource = utils.MockResource(self)
+    cms = ClouderaManager(resource)
+
+    resource.expect("POST", "/cm/commands/hostsDecommission",
+        data=[ "host1", "host2" ],
+        retdata={})
+    cms.hosts_decommission([ "host1", "host2" ])
+
+    resource.expect("POST", "/cm/commands/hostsRecommissionWithStart",
+        data=[ "host1", "host2" ],
+        retdata={})
+    cms.hosts_recommission_with_start([ "host1", "host2" ])
+
   def test_get_licensed_feature_usage(self):
     resource = utils.MockResource(self)
     cms = ClouderaManager(resource)