def clean_queues()

in clone_mediaconvert_resources/clone_mediaconvert_resources.py [0:0]

• 33 lines of code
• 11 McCabe index (conditional complexity)

def clean_queues(dirty_queues, file):
    try:
        clean_queues = []
        resource_arns = []

        for queue in dirty_queues:

            # Check for On-Demand Queue since we only support migrating those and no Default queues
            if queue['PricingPlan'] == 'ON_DEMAND' and queue['Name'] != 'Default':
                clean_queues_struct = {'Name': queue['Name'], 'Description': ''}
                if 'Category' in queue:
                    clean_queues_struct['Category'] = queue['Category']

                if 'Description' in queue:
                    clean_queues_struct['Description'] = queue['Description']

                clean_queues.append(clean_queues_struct)
                resource_arns.append(queue['Arn'])

        get_resource_tags(resource_arns, file)

        if file == "single":
            if not os.path.exists('queues'):
                create_directory("queues")

            with open('queues/list.json', 'w') as output_file:
                json.dump(clean_queues, output_file)
            return 'queues/list.json'
        else:
            t = time.time()
            working_directory = "queue_" + str(int(t))
            create_directory(working_directory)

            for c_queues in clean_queues:
                filename = c_queues['Name'] + ".json"
                with open(working_directory + '/' + filename, 'w+') as output_file:
                    json.dump(c_queues, output_file)
            return working_directory
    except:
        print("Error: Unknown Error when trying to create queue file")
        shutil.rmtree("queues")
        exit(-1)