| 123456789101112131415161718 |
- import sqlalchemy as sa
- from alembic import op
- from sqlalchemy.dialects import mysql
- revision = "0026_business_poll"
- down_revision = "0025_business_wait"
- branch_labels = None
- depends_on = None
- def upgrade():
- # 持久核对时间保证多进程轮询不会反复只处理最早的100个等待运行。
- op.add_column("agent_runs", sa.Column(
- "business_checked_at", mysql.DATETIME(fsp=6), nullable=True))
- def downgrade():
- op.drop_column("agent_runs", "business_checked_at")
|
