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")