(commit=False)
return sum(bytes_deleted_list)
Wipe shards in parallel
Wipe shards in parallel
Wipe shards in parallel
async def wipe_blobdb(commit=False):
    """
    Wipe shards in parallel
    """
    coros = [wipe_shard(dbname, commit)
             for dbname in get_db_aliases_for_partitioned_query()]
    bytes_deleted_list = await asyncio.gather(*coros)
    return sum(bytes_deleted_list)
async def wipe_blobdb ( commit = False ) : coros = [ wipe_shard ( dbname , commit ) for dbname in get_db_aliases_for_partitioned_query ( ) ] bytes_deleted_list = await asyncio . gather ( * coros ) return sum ( bytes_deleted_list )