def upgrade():
'''
upgrade method
'''
create_table('rse_transfer_limits',
sa.Column('rse_id', GUID()),
sa.Column('activity', sa.String(50)),
sa.Column('rse_expression', sa.String(3000)),
sa.Column('max_transfers', sa.BigInteger),
sa.Column('transfers', sa.BigInteger),
sa.Column('waitings', sa.BigInteger),
sa.Column('updated_at', sa.DateTime),
sa.Column('created_at', sa.DateTime))
if context.get_context().dialect.name != 'sqlite':
create_primary_key('RSE_TRANSFER_LIMITS_PK', 'rse_transfer_limits', ['rse_id', 'activity'])
create_check_constraint('RSE_TRANSFER_LIMITS_CREATED_NN', 'rse_transfer_limits', 'created_at is not null')
create_check_constraint('RSE_TRANSFER_LIMITS_UPDATED_NN', 'rse_transfer_limits', 'updated_at is not null')
create_foreign_key('RSE_TRANSFER_LIMITS_RSE_ID_FK', 'rse_transfer_limits', 'rses', ['rse_id'], ['id'])
379a19b5332d_create_rse_limits_table.py 文件源码
python
阅读 24
收藏 0
点赞 0
评论 0
评论列表
文章目录