original_docstring: End-to-End test for a simple pipeline.
docstring: End-to-End test for a simple pipeline.
docstring_tokens: End - to - End test for a simple pipeline .
code: def testSimpleEnd2EndPipeline(self):
      """End-to-End test for a simple pipeline."""
      pipeline_name = 'kubeflow-v2-fbeg-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,
          csv_input_location=_TEST_DATA_ROOT)
  
      beam_pipeline_args = [
          '--temp_location=' +
          os.path.join(self._pipeline_root(pipeline_name), 'dataflow', 'temp'),
          '--project={}'.format(self._GCP_PROJECT_ID)
      ]
  
      pipeline = self._create_pipeline(pipeline_name, components,
                                       beam_pipeline_args)
  
      self._run_pipeline(pipeline)
code_tokens: def testSimpleEnd2EndPipeline ( self ) : pipeline_name = 'kubeflow-v2-fbeg-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 , csv_input_location = _TEST_DATA_ROOT ) beam_pipeline_args = [ '--temp_location=' + os . path . join ( self . _pipeline_root ( pipeline_name ) , 'dataflow' , 'temp' ) , '--project={}' . format ( self . _GCP_PROJECT_ID ) ] pipeline = self . _create_pipeline ( pipeline_name , components , beam_pipeline_args ) self . _run_pipeline ( pipeline )
short_docstring: End-to-End test for a simple pipeline.
short_docstring_tokens: End - to - End test for a simple pipeline .
comment: """End-to-End test for a simple pipeline."""