docstr: Tuner-only pipeline for distributed Tuner flock on Vertex AI Training.
docstr_tok: ["Tuner-only","pipeline","for","distributed","Tuner","flock","on","Vertex","AI","Training","."]
code: def testVertexDistributedTunerPipeline(self):
      """Tuner-only pipeline for distributed Tuner flock on Vertex AI Training."""
      pipeline_name = self._make_unique_pipeline_name(
          "kubeflow-vertex-dist-tuner"
      )
      pipeline = self._create_pipeline(
          pipeline_name,
          [
              self.penguin_examples_importer,
              self.penguin_schema_importer,
              ai_platform_tuner_component.Tuner(
                  examples=self.penguin_examples_importer.outputs[
                      "result"
                  ],
                  module_file=self._penguin_tuner_module,
                  schema=self.penguin_schema_importer.outputs["result"],
                  train_args=trainer_pb2.TrainArgs(num_steps=10),
                  eval_args=trainer_pb2.EvalArgs(num_steps=5),
                  # 3 worker parallel tuning.
                  tune_args=tuner_pb2.TuneArgs(num_parallel_trials=3),
                  custom_config={
                      ai_platform_tuner_executor.TUNING_ARGS_KEY: self._getVertexTrainingArgs(
                          pipeline_name
                      ),
                      constants.ENABLE_VERTEX_KEY: True,
                      constants.VERTEX_REGION_KEY: self._GCP_REGION,
                  },
              ),
          ],
      )
      self._compile_and_run_pipeline(pipeline)
      self._assertHyperparametersAreWritten(pipeline_name)
  
imports: import os
  import absl
  from googleapiclient import discovery
  from googleapiclient import errors
  import tensorflow
  from tfx import v1
  from tfx.components.pusher.component import Pusher
  from tfx.components.trainer.component import Trainer
  from tfx.dsl.components.base import executor_spec
  from tfx.dsl.components.common import importer
  from tfx.dsl.io import fileio
  from tfx.extensions.google_cloud_ai_platform import constants
  from tfx.extensions.google_cloud_ai_platform import runner
  from tfx.extensions.google_cloud_ai_platform.pusher import executor
  from tfx.extensions.google_cloud_ai_platform.trainer import executor
  from tfx.extensions.google_cloud_ai_platform.tuner import component
  from tfx.extensions.google_cloud_ai_platform.tuner import executor
  from tfx.extensions.google_cloud_big_query.pusher import executor
  from tfx.orchestration import test_utils
  from tfx.orchestration.kubeflow import test_utils
  from tfx.proto import trainer_pb2
  from tfx.proto import tuner_pb2
  from tfx.types import standard_artifacts
  from tfx.utils import path_utils
  from tfx.utils import telemetry_utils
label_desc: Use image node_id 11 for calling the KubeflowGCPIntegrationTest obj's underlying member method code with example usage: obj.testVertexDistributedTunerPipeline() without return types