17def upgrade():
   18    op.create_table(
   19        'ps_subscription_persistence',
   20        sa.Column('id', sa.String(40), nullable=False, unique=True),
   21    sa.Column('packet', sa.String(2048)),
   22    sa.Column('src_name', sa.String(128)),
   23    sa.Column('src_port', sa.Integer),
   24    sa.Column('transport_key', sa.String(64)),
   25    sa.Column('local_name', sa.String(128)),
   26    sa.Column('local_port', sa.Integer),
   27    sa.Column('cseq', sa.Integer),
   28    sa.Column('tag', sa.String(128)),
   29    sa.Column('endpoint', sa.String(40)),
   30    sa.Column('expires', sa.Integer),
   31    )
   32 
   33    op.create_index('ps_subscription_persistence_id', 'ps_subscription_persistence', ['id'])
   34