code: def upgrade():
      """Apply add cleared column to dagrun"""
      conn = op.get_bind()
      if conn.dialect.name == "mssql":
          with op.batch_alter_table("dag_run") as batch_op:
              batch_op.add_column(
                  sa.Column("clear_number", sa.Integer, default=0)
              )
              batch_op.alter_column(
                  "clear_number",
                  existing_type=sa.Integer,
                  nullable=False,
              )
      else:
          with op.batch_alter_table("dag_run") as batch_op:
              batch_op.add_column(
                  sa.Column(
                      "clear_number",
                      sa.Integer,
                      default=0,
                      nullable=False,
                      server_default="0",
                  )
              )
  
imports: import sqlalchemy
  from alembic import op
label_desc: Use image node_id 1 for calling a global function with example usage: upgrade() without return types