code: def upgrade():
      conn = op.get_bind()
      session = sa.orm.Session(bind=conn)
  
      with op.batch_alter_table("predictor", schema=None) as batch_op:
          batch_op.add_column(
              sa.Column("deleted_at", sa.DateTime(), nullable=True)
          )
          batch_op.add_column(
              sa.Column("active", sa.Boolean(), nullable=True)
          )
  
      conn.execute(
          text(
              """
          update predictor set active = :val;
      """
          ),
          {"val": True},
      )
  
      session.commit()
  
imports: from alembic import op
  import sqlalchemy
  from sqlalchemy.sql import text
  import mindsdb.interfaces.storage.db
label_desc: Use image node_id 1 for calling a global function with example usage: upgrade() without return types