from glaciertests.util import GlacierTestsConfig

def purge_prefix_vaults():
    conn = GlacierTestsConfig().connection()
    all_vaults = conn.list_vaults()
    for vault in all_vaults['VaultList']:
        if vault['VaultName'].startswith(GlacierTestsConfig().prefix()):
            conn.delete_vault(vault['VaultName'])

def setup():
    purge_prefix_vaults()

def teardown():
    purge_prefix_vaults()

from glaciertests.util import GlacierTestsConfig


def purge_prefix_vaults():
    conn = GlacierTestsConfig().connection()
    all_vaults = conn.list_vaults()
    jobs = {}
    for vault in all_vaults['VaultList']:
        if vault['VaultName'].startswith(GlacierTestsConfig().prefix()):
            # Try to delete and only schedule an inventory job if delete fails
            try:
                conn.delete_vault(vault['VaultName'])
            except Exception as e:
                jobs[vault['VaultName']] = enumerate_vault(vault['VaultName'],
                                                           conn)
    while jobs:
        remaining = {}
        while jobs:
            vault, job_id = jobs.popitem()
            status = conn.describe_job(vault, job_id)
            if status['Completed'] == 'false':
                remaining[vault] = job_id
                continue
            resp = conn.get_job_output(vault, job_id)
            for archive in resp['ArchiveList']:
                conn.delete_archive(vault, archive['ArchiveId'])
        jobs = remaining


def enumerate_vault(vault, conn):
    job_data = {
                'Type': 'inventory-retrieval',
               }
    result = conn.initiate_job(vault, job_data)
    print(result)
    return result['JobId']


def setup():
    purge_prefix_vaults()


def teardown():
    purge_prefix_vaults()

Remove vaults with data before and after tests.