code: def testCreateRun(self, mock_pipeline_job, mock_init):
      flags_dict = {
          labels.ENGINE_FLAG: self.engine,
          labels.PIPELINE_NAME: self.pipeline_name,
          labels.GCP_PROJECT_ID: _TEST_PROJECT_1,
          labels.GCP_REGION: _TEST_REGION,
          labels.RUNTIME_PARAMETER: self.runtime_parameter,
      }
  
      handler = vertex_handler.VertexHandler(flags_dict)
      handler.create_run()
  
      mock_init.assert_called_once_with(
          project=_TEST_PROJECT_1, location=_TEST_REGION
      )
      mock_pipeline_job.assert_called_once_with(
          display_name=_TEST_PIPELINE_NAME,
          template_path=handler._get_pipeline_definition_path(
              _TEST_PIPELINE_NAME
          ),
          parameter_values={"a": "1", "b": "2"},
      )
      mock_pipeline_job.return_value.submit.assert_called_once()
  
imports: import os
  import sys
  from unittest import mock
  from google.cloud import aiplatform
  from google.cloud.aiplatform import pipeline_jobs
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.tools.cli import labels
  from tfx.tools.cli.handler import vertex_handler
  from tfx.utils import test_case_utils
label_desc: Use image node_id 11 for calling the VertexHandlerTest obj's underlying member method code with example usage: obj.testCreateRun(mock_pipeline_job, mock_init) without return types