code: def _create_pipeline() -> pipeline_module.Pipeline:
      """Create sample container component pipeline."""
  
      pipeline_name = _pipeline_name
      pipeline_root = _pipeline_root
  
      text_url = "https://raw.githubusercontent.com/karpathy/char-rnn/370cbcd/data/tinyshakespeare/input.txt"
      pattern = "art thou"
      components = create_pipeline_component_instances(
          text_url, pattern
      )
  
      # Use the default in-cluster MySql metadata config.
      config = (
          kubernetes_dag_runner.get_default_kubernetes_metadata_config()
      )
  
      return pipeline_module.Pipeline(
          pipeline_name=pipeline_name,
          pipeline_root=pipeline_root,
          components=components,
          metadata_connection_config=config,
          enable_cache=False,
      )
  
imports: import absl
  from tfx.orchestration import pipeline
  from tfx.orchestration.experimental.kubernetes import kubernetes_dag_runner
  from tfx.orchestration.test_pipelines.download_grep_print_pipeline import create_pipeline_component_instances
label_desc: Use image node_id 1 for calling a global function with example usage: _create_pipeline() and returns: pipeline_module