code: def create_test_pipeline():
      """Builds a consumer pipeline that gets artifacts from another project."""
      external_examples = (
          channel_utils.external_pipeline_artifact_query(
              artifact_type=standard_artifacts.Examples,
              owner="owner",
              pipeline_name="producer-pipeline",
              producer_component_id="producer-component-id",
              output_key="output-key",
              pipeline_run_id="pipeline-run-id",
          )
      )
  
      example_gen_resolver = resolver.Resolver(
          strategy_class=latest_artifacts_resolver.LatestArtifactsResolver,
          examples=external_examples,
      ).with_id("Resolver.example_gen_resolver")
  
      statistics_gen = StatisticsGen(
          examples=example_gen_resolver.outputs["examples"]
      )
  
      return pipeline.Pipeline(
          pipeline_name="consumer-pipeline",
          components=[example_gen_resolver, statistics_gen],
      )
  
imports: from tfx.components import StatisticsGen
  from tfx.dsl.components.common import resolver
  from tfx.dsl.experimental import latest_artifacts_resolver
  from tfx.orchestration import pipeline
  from tfx.types import channel_utils
  from tfx.types import standard_artifacts
label_desc: Use image node_id 1 for calling a global function with example usage: create_test_pipeline() and returns: pipeline