code: def _two_step_pipeline() -> tfx_pipeline.Pipeline:
      default_input_config = json.dumps(
          {
              "splits": [
                  {
                      "name": "single_split",
                      "pattern": "SELECT * FROM default-table",
                  }
              ]
          }
      )
      input_config = data_types.RuntimeParameter(
          name="input_config", ptype=str, default=default_input_config
      )
      example_gen = big_query_example_gen_component.BigQueryExampleGen(
          input_config=input_config,
          output_config=example_gen_pb2.Output(),
      )
      statistics_gen = statistics_gen_component.StatisticsGen(
          examples=example_gen.outputs["examples"]
      )
      return tfx_pipeline.Pipeline(
          pipeline_name="two_step_pipeline",
          pipeline_root="pipeline_root",
          metadata_connection_config=metadata_store_pb2.ConnectionConfig(),
          components=[example_gen, statistics_gen],
      )
  
imports: import json
  import os
  import tarfile
  from typing import List
  from kfp import onprem
  import tensorflow
  from tfx.components.statistics_gen import component
  from tfx.dsl.component.experimental import executor_specs
  from tfx.dsl.component.experimental.annotations import Parameter
  from tfx.dsl.component.experimental.decorators import component
  from tfx.dsl.components.base import base_component
  from tfx.dsl.io import fileio
  from tfx.extensions.google_cloud_big_query.example_gen import component
  from tfx.orchestration import data_types
  from tfx.orchestration import pipeline
  from tfx.orchestration.kubeflow import kubeflow_dag_runner
  from tfx.orchestration.kubeflow.decorators import FinalStatusStr
  from tfx.proto import example_gen_pb2
  from tfx.types import component_spec
  from tfx.utils import telemetry_utils
  from tfx.utils import test_case_utils
  import yaml
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling a global function with example usage: _two_step_pipeline() and returns: tfx_pipeline