in scale_test_tool/tasks/virtual_cluster_task.py [0:0]
def create_namespace_and_virtual_cluster(self, test_id):
# Creating namespace in EKS cluster
kubernetes_ns = self._generate_namespace_name(test_id)
subprocess.run(["sh", "scripts/create_new_namespace_setup_emr_on_eks.sh",
REGION, EKS_CLUSTER_NAME, kubernetes_ns])
# Creating virtual cluster
virtual_cluster_name = self._generate_virtual_cluster_name(test_id)
create_virtual_cluster_response = create_virtual_cluster(
client=self.emr_containers_client,
client_token=test_id,
virtual_cluster_name=virtual_cluster_name,
eks_cluster_name=EKS_CLUSTER_NAME,
k8s_namespace=kubernetes_ns)
return create_virtual_cluster_response['id']