code: def downgrade():
      """Unapply Remove id column from xcom"""
      conn = op.get_bind()
      with op.batch_alter_table("xcom") as bop:
          if conn.dialect.name != "mssql":
              bop.drop_constraint("pk_xcom", type_="primary")
          bop.add_column(Column("id", Integer, nullable=False))
          bop.create_primary_key("id", ["id"])
          bop.create_index(
              "idx_xcom_dag_task_date",
              ["dag_id", "task_id", "key", "execution_date"],
          )
  
file_path: airflow/airflow/migrations/versions/0060_2_0_0_remove_id_column_from_xcom.py
imports: from __future__ import annotations
  from collections import defaultdict
  from alembic import op
  from sqlalchemy import Column, Integer, inspect, text
label_desc: Use image node_id 5 for calling a global function with example usage: downgrade() without return types