Synnefo

Statistics = namedtuple('Statistics', ('node', 'path', 'size', 'cluster'))

ResetHoldingPayload = namedtuple('ResetHoldingPayload', (

backend = get_backend()

table = {}

table['policy'] = backend.node.policy

conn = backend.node.conn

def _compute_statistics(nodes):

    statistics = []

    append = statistics.append

    for path, node in nodes:

        select_children = select(

        select_descendants = select([table['nodes'].c.node]).where(

            or_(table['nodes'].c.parent.in_(select_children),

                table['nodes'].c.node.in_(select_children)))

                cluster=cluster))

    return statistics

def _get_verified_usage(statistics):

    reset_holding = []

    append = reset_holding.append

    for item in statistics:

            continue

        try:

            assert item.size == db_item.size, \

        except AssertionError, e:

            print e

        if item.cluster == CLUSTER_NORMAL:

                self.stdout.write(

                        'Unknown quotaholder accounts: %s\n' %

                        ','.join(missing_entities))

                missing_indexes = set(result)

                reset_holding = [x for i, x in enumerate(reset_holding)

                                 if i not in missing_indexes]