code: def _prepare_airflow_with_mysql(self):
      self._mysql_container_name = (
          "airflow_" + test_utils.generate_random_id()
      )
      ip_address, db_port = airflow_test_utils.create_mysql_container(
          self._mysql_container_name
      )
      self.addCleanup(self._cleanup_mysql_container)
      self.enter_context(
          test_case_utils.override_env_var(
              "AIRFLOW__CORE__SQL_ALCHEMY_CONN",
              "mysql://tfx@%s:%d/airflow" % (ip_address, db_port),
          )
      )
      # Do not load examples to make this a bit faster.
      self.enter_context(
          test_case_utils.override_env_var(
              "AIRFLOW__CORE__LOAD_EXAMPLES", "False"
          )
      )
  
      self._airflow_initdb()
  
imports: import codecs
  import locale
  import os
  import subprocess
  import sys
  import time
  import absl
  from click import testing
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.orchestration.airflow import test_utils
  from tfx.tools.cli import labels
  from tfx.tools.cli import pip_utils
  from tfx.tools.cli.cli_main import cli_group
  from tfx.tools.cli.e2e import test_utils
  from tfx.utils import io_utils
  from tfx.utils import retry
  from tfx.utils import test_case_utils
label_desc: Use image node_id 6 for calling the CliAirflowEndToEndTest obj's underlying member method code with example usage: obj._prepare_airflow_with_mysql() without return types