in scale_test_tool/tasks/virtual_cluster_task.py [0:0]
def _is_virtual_cluster_ready_for_cleanup(self, virtual_cluster_id):
list_job_run_response = list_job_run_in_running_state(
client=self.emr_containers_client,
virtual_cluster_id=virtual_cluster_id,
states_list=JOB_RUNNING_STATES
)
if list_job_run_response['jobRuns']:
return False
return True