docstr: End-to-End test for a simple pipeline.
code: def testSimpleEnd2EndPipeline(self, moke_resolve_dependencies):
      """End-to-End test for a simple pipeline."""
      moke_resolve_dependencies.return_value = None
      pipeline_name = "kubeflow-v2-bqeg-test-{}".format(
          test_utils.random_id()
      )
  
      components = kubeflow_v2_test_utils.create_pipeline_components(
          pipeline_root=self._pipeline_root(pipeline_name),
          transform_module=self._MODULE_FILE,
          trainer_module=self._MODULE_FILE,
          bigquery_query=_BIGQUERY_QUERY,
      )
  
      beam_pipeline_args = [
          "--temp_location="
          + os.path.join(
              self._pipeline_root(pipeline_name), "dataflow", "temp"
          ),
          "--project={}".format(self._GCP_PROJECT_ID),
          # TODO(b/171733562): Remove `use_runner_v2` once it is the default for
          # Dataflow.
          "--experiments=use_runner_v2",
          "--worker_harness_container_image=%s" % self.container_image,
      ]
  
      pipeline = self._create_pipeline(
          pipeline_name, components, beam_pipeline_args
      )
  
      self._run_pipeline(pipeline)
      moke_resolve_dependencies.assert_called()
  
file_path: tfx/tfx/orchestration/kubeflow/v2/e2e_tests/bigquery_integration_test.py
imports: import os
  from unittest import mock
  import tensorflow
  from tfx.dsl.components.base import base_component
  from tfx.orchestration import test_utils
  from tfx.orchestration.kubeflow.v2 import test_utils
  from tfx.orchestration.kubeflow.v2.e2e_tests import base_test_case
label_desc: Use image node_id 1 for calling the BigqueryIntegrationTest obj's underlying member method code with example usage: obj.testSimpleEnd2EndPipeline(moke_resolve_dependencies) without return types