docstr: Trainer-only test pipeline on AI Platform Training.
docstr_tok: ["Trainer-only","test","pipeline","on","AI","Platform","Training","."]
code: def testAIPlatformTrainerPipeline(self):
      """Trainer-only test pipeline on AI Platform Training."""
      pipeline_name = self._make_unique_pipeline_name(
          "kubeflow-aip-trainer"
      )
      pipeline = self._create_pipeline(
          pipeline_name,
          [
              self.schema_importer,
              self.transformed_examples_importer,
              self.transform_graph_importer,
              Trainer(
                  custom_executor_spec=executor_spec.ExecutorClassSpec(
                      ai_platform_trainer_executor.Executor
                  ),
                  module_file=self._trainer_module,
                  transformed_examples=self.transformed_examples_importer.outputs[
                      "result"
                  ],
                  schema=self.schema_importer.outputs["result"],
                  transform_graph=self.transform_graph_importer.outputs[
                      "result"
                  ],
                  train_args=trainer_pb2.TrainArgs(num_steps=10),
                  eval_args=trainer_pb2.EvalArgs(num_steps=5),
                  custom_config={
                      ai_platform_trainer_executor.TRAINING_ARGS_KEY: self._getCaipTrainingArgsForDistributed(
                          pipeline_name
                      )
                  },
              ),
          ],
      )
      self._compile_and_run_pipeline(pipeline)
      self._assertNumberOfTrainerOutputIsOne(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 7 for calling the KubeflowGCPIntegrationTest obj's underlying member method code with example usage: obj.testAIPlatformTrainerPipeline() without return types