code: def tables():
      global task_instance, task_fail, dag_run
      metadata = sa.MetaData()
      task_instance = sa.Table(
          "task_instance",
          metadata,
          sa.Column("task_id", StringID()),
          sa.Column("dag_id", StringID()),
          sa.Column("run_id", StringID()),
          sa.Column("map_index", sa.Integer(), server_default="-1"),
          sa.Column("execution_date", TIMESTAMP),
      )
      task_fail = sa.Table(
          "task_fail",
          metadata,
          sa.Column("dag_id", StringID()),
          sa.Column("task_id", StringID()),
          sa.Column("run_id", StringID()),
          sa.Column("map_index", StringID()),
          sa.Column("execution_date", TIMESTAMP),
      )
      dag_run = sa.Table(
          "dag_run",
          metadata,
          sa.Column("dag_id", StringID()),
          sa.Column("run_id", StringID()),
          sa.Column("execution_date", TIMESTAMP),
      )
  
file_path: airflow/airflow/migrations/versions/0105_2_3_0_add_map_index_to_taskfail.py
imports: from __future__ import annotations
  import sqlalchemy
  from alembic import op
  from sqlalchemy.sql import ColumnElement, Update, and_, select
  from airflow.migrations.db_types import TIMESTAMP, StringID
label_desc: Use image node_id 1 for calling a global function with example usage: tables() without return types