Synnefo

"""Fix latest_version

Revision ID: 3dd56e750a3

Revises: 230f8ce9c90f

Create Date: 2012-07-19 14:36:24.242310

"""

# revision identifiers, used by Alembic.

revision = '3dd56e750a3'

down_revision = '230f8ce9c90f'

from alembic import op

import sqlalchemy as sa

from sqlalchemy.sql import table, column

from sqlalchemy.sql.expression import desc

def upgrade():

    n = table('nodes',

              column('node', sa.Integer),

              column('latest_version', sa.Integer)

              )

    v = table('versions',

              column('node', sa.Integer),

              column('mtime', sa.Integer),

              column('serial', sa.Integer),

              )

    s = sa.select([v.c.serial]).where(

        n.c.node == v.c.node).order_by(desc(v.c.mtime)).limit(1)

    op.execute(

        n.update().

        values({'latest_version': s})

    )

def downgrade():

    pass