def labelNodes()

in scripts/cpd_install.py [0:0]
23 lines of code
4 McCabe index (conditional complexity)

    def labelNodes(self,icpdInstallLogFile):
        methodName = "labelNodes"
        TR.info(methodName,"  Start Label nodes for Portworx Installation")
        """
        WORKER_NODES=`oc get nodes | grep worker | awk '{print $1}'`
        for wnode in ${WORKER_NODES[@]}; do
        oc label nodes $wnode node-role.kubernetes.io/compute=true
        done
        """

        get_nodes = "oc get nodes | grep worker | awk '{print $1}'"
        TR.info(methodName,"Run get_nodes command %s"%get_nodes)
        try:
            worker_nodes = check_output(['bash','-c', get_nodes]) 
            TR.info(methodName,"Completed %s command with return value %s" %(get_nodes,worker_nodes))
            nodes = worker_nodes.split("\n")
            TR.info(methodName,"worker nodes %s"%nodes)
        except CalledProcessError as e:
            TR.error(methodName,"command '{}' return with error (code {}): {}".format(e.cmd, e.returncode, e.output))    
        i =0
        while i < len(nodes)-1:
            TR.info(methodName,"Labeling for worker node  %s " %nodes[i])
            label_cmd = "oc label nodes "+nodes[i]+" node-role.kubernetes.io/compute=true"
            try:
                retcode = check_output(['bash','-c', label_cmd])
                TR.info(methodName,"Label for Worker node  %s returned %s" %(nodes[i],retcode))
            except CalledProcessError as e:
                TR.error(methodName,"command '{}' return with error (code {}): {}".format(e.cmd, e.returncode, e.output))    
            i += 1

        TR.info(methodName,"Done Label nodes for Portworx Installation")