code: def testPipelineSchemaSuccessfulRun(self):
      # First create a pipeline.
      flags_dict = {
          labels.ENGINE_FLAG: self.engine,
          labels.PIPELINE_DSL_PATH: self.pipeline_path,
      }
      handler = local_handler.LocalHandler(flags_dict)
      handler.create_pipeline()
  
      flags_dict = {
          labels.ENGINE_FLAG: self.engine,
          labels.PIPELINE_NAME: self.pipeline_name,
      }
      handler = local_handler.LocalHandler(flags_dict)
      # Create fake schema in pipeline root.
      component_output_dir = os.path.join(
          self.pipeline_root, "SchemaGen"
      )
      schema_path = base_driver._generate_output_uri(  # pylint: disable=protected-access
          component_output_dir, "schema", 3
      )
  
      fileio.makedirs(schema_path)
      with open(os.path.join(schema_path, "schema.pbtxt"), "w") as f:
          f.write("SCHEMA")
      with self.captureWritesToStream(sys.stdout) as captured:
          handler.get_schema()
          curr_dir_path = os.path.abspath("schema.pbtxt")
          self.assertIn(
              "Path to schema: {}".format(curr_dir_path),
              captured.contents(),
          )
          self.assertIn(
              "*********SCHEMA FOR {}**********".format(
                  self.pipeline_name.upper()
              ),
              captured.contents(),
          )
          self.assertTrue(fileio.exists(curr_dir_path))
  
imports: import json
  import os
  import subprocess
  import sys
  from unittest import mock
  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 local_handler
  from tfx.utils import test_case_utils
label_desc: Use image node_id 16 for calling the LocalHandlerTest obj's underlying member method code with example usage: obj.testPipelineSchemaSuccessfulRun() without return types