def delete_job_queue()

in lib/workshop.py [0:0]

• 36 lines of code
• 8 McCabe index (conditional complexity)

def delete_job_queue(job_queue):
    batch = boto3.client('batch')
    job_queues = [job_queue]
    response = describe_job_queues(job_queues)
    
    try:        
        if response['jobQueues'][0]['state'] != 'DISABLED':
            try:
                batch.update_job_queue(
                    jobQueue=job_queue,
                    state='DISABLED'
                )
            except ClientError as e:
                print(e.response['Error']['Message'])
                raise

        terminate_jobs(job_queue)

        # Wait until job queue is DISABLED
        response = describe_job_queues(job_queues)
        while response['jobQueues'][0]['state'] != 'DISABLED':
            time.sleep(5)
            response = describe_job_queues(job_queues)

        time.sleep(10)
        if response['jobQueues'][0]['status'] != 'DELETING':
            try:
                batch.delete_job_queue(
                    jobQueue=job_queue,
                )
            except ClientError as e:
                print(e.response['Error']['Message'])
                raise

        response = describe_job_queues(job_queues)

        while response['jobQueues'][0]['status'] == 'DELETING':
            time.sleep(5)
            response = describe_job_queues(job_queues)

            if len(response['jobQueues']) != 1:
                break
    except:
        print("Job queue doesn't exist, skip")