code: def testCreateRun(self, mock_call):
      # Create a pipeline in dags folder.
      handler_pipeline_path = os.path.join(
          os.environ["AIRFLOW_HOME"],
          "dags",
          self.pipeline_args[labels.PIPELINE_NAME],
      )
      fileio.makedirs(handler_pipeline_path)
  
      # Now run the pipeline
      flags_dict = {
          labels.ENGINE_FLAG: self.engine,
          labels.PIPELINE_NAME: self.pipeline_name,
          labels.RUNTIME_PARAMETER: self.runtime_parameter,
      }
      handler = airflow_handler.AirflowHandler(flags_dict)
      handler.create_run()
  
      self.assertEqual(mock_call.call_count, 2)
      self.assertEqual(
          ["airflow", "dags", "unpause", self.pipeline_name],
          mock_call.call_args_list[0][0][0],
      )
      self.assertEqual(
          [
              "airflow",
              "dags",
              "trigger",
              "--conf",
              self.runtime_parameter_json,
              self.pipeline_name,
          ],
          mock_call.call_args_list[1][0][0],
      )
  
imports: import json
  import os
  import subprocess
  import sys
  from unittest import mock
  import click
  import tensorflow
  from tfx.dsl.components.base import base_driver
  from tfx.dsl.io import fileio
  from tfx.tools.cli import labels
  from tfx.tools.cli.handler import airflow_handler
  from tfx.utils import io_utils
  from tfx.utils import test_case_utils
label_desc: Use image node_id 16 for calling the AirflowHandlerTest obj's underlying member method code with example usage: obj.testCreateRun(mock_call) without return types