def delete_virtual_cluster_namespace()

in scale_test_tool/tasks/virtual_cluster_task.py [0:0]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    def delete_virtual_cluster_namespace(self, virtual_cluster_id, test_id):
        ready_for_cleanup = self._is_virtual_cluster_ready_for_cleanup(virtual_cluster_id)
        while ready_for_cleanup is False:
            logger.info(f"Waiting for all jobs to terminate in Virtual Cluster {virtual_cluster_id}")
            time.sleep(10)
            ready_for_cleanup = self._is_virtual_cluster_ready_for_cleanup(virtual_cluster_id)

        logger.info(f"No running jobs, {virtual_cluster_id} can be now terminated")
        delete_virtual_cluster(
            client=self.emr_containers_client,
            virtual_cluster_id=virtual_cluster_id
        )
        logger.info(f"Virtual cluster {virtual_cluster_id} has been terminated")
        kubernetes_ns = self._generate_namespace_name(test_id)
        subprocess.run(["sh", "scripts/delete_namespace.sh", kubernetes_ns])
        logger.info(f"Namespace {kubernetes_ns} has been Deleted")