code: def _mysql_TIMESTAMP():
      from sqlalchemy.dialects import mysql
  
      class TIMESTAMP(mysql.TIMESTAMP):
          def __init__(self, *args, fsp=6, timezone=True, **kwargs):
              super().__init__(
                  *args, fsp=fsp, timezone=timezone, **kwargs
              )
  
      return TIMESTAMP
  
file_path: airflow/airflow/migrations/db_types.py
imports: from __future__ import annotations
  import sqlalchemy
  from alembic import context
  from lazy_object_proxy import Proxy
label_desc: Use image node_id 2 for calling a global function with example usage: _mysql_TIMESTAMP() and returns: TIMESTAMP