def upgrade():
op.add_column('pod_states', sa.Column('kube_id', sa.Integer(),
nullable=True))
session = sa.orm.sessionmaker()(bind=op.get_bind())
for (pod_id, kube_id) in session.query(Pod.id, Pod.kube_id):
session.query(PodState).filter_by(pod_id=pod_id).update(
{'kube_id': kube_id})
session.commit()
op.alter_column('pod_states', 'kube_id', nullable=False)
50e4a32fa6c3_add_kube_id_field_to_PodState.py 文件源码
python
阅读 25
收藏 0
点赞 0
评论 0
评论列表
文章目录