Revision 2715ade4 snf-pithos-backend/pithos/backends/lib/sqlalchemy/alembic/versions/3dd56e750a3_fix_latest_version.py
b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/alembic/versions/3dd56e750a3_fix_latest_version.py | ||
---|---|---|
15 | 15 |
from sqlalchemy.sql import table, column |
16 | 16 |
from sqlalchemy.sql.expression import desc |
17 | 17 |
|
18 |
|
|
18 | 19 |
def upgrade(): |
19 |
n = table('nodes', |
|
20 |
column('node', sa.Integer), |
|
21 |
column('latest_version', sa.Integer) |
|
22 |
) |
|
23 |
v = table('versions', |
|
24 |
column('node', sa.Integer), |
|
25 |
column('mtime', sa.Integer), |
|
26 |
column('serial', sa.Integer), |
|
27 |
) |
|
28 |
|
|
29 |
s = sa.select([v.c.serial]).where(n.c.node == v.c.node).order_by(desc(v.c.mtime)).limit(1) |
|
20 |
n = table('nodes', |
|
21 |
column('node', sa.Integer), |
|
22 |
column('latest_version', sa.Integer) |
|
23 |
) |
|
24 |
v = table('versions', |
|
25 |
column('node', sa.Integer), |
|
26 |
column('mtime', sa.Integer), |
|
27 |
column('serial', sa.Integer), |
|
28 |
) |
|
29 |
|
|
30 |
s = sa.select([v.c.serial]).where( |
|
31 |
n.c.node == v.c.node).order_by(desc(v.c.mtime)).limit(1) |
|
30 | 32 |
op.execute( |
31 |
n.update().\
|
|
32 |
values({'latest_version':s})
|
|
33 |
)
|
|
33 |
n.update(). |
|
34 |
values({'latest_version': s})
|
|
35 |
) |
|
34 | 36 |
|
35 | 37 |
|
36 | 38 |
def downgrade(): |
Also available in: Unified diff