code: def upgrade():
      """Add pid column to task_instance table."""
      op.add_column("task_instance", sa.Column("pid", sa.Integer))
  
imports: from __future__ import annotations
  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