code: def testPenguinPipelineLocalWithImporter(self):
      module_file = self._module_file_name("keras")
      LocalDagRunner().run(
          penguin_pipeline_local.create_pipeline(
              pipeline_name=self._pipeline_name,
              data_root=self._data_root,
              module_file=module_file,
              accuracy_threshold=0.1,
              serving_model_dir=self._serving_model_dir,
              pipeline_root=self._pipeline_root,
              metadata_path=self._metadata_path,
              user_provided_schema_path=self._schema_path,
              enable_tuning=False,
              enable_bulk_inferrer=False,
              examplegen_input_config=None,
              examplegen_range_config_date=None,
              resolver_range_config=None,
              beam_pipeline_args=[],
              enable_transform_input_cache=False,
              enable_example_diff=False,
          )
      )
  
      self.assertTrue(fileio.exists(self._serving_model_dir))
      self.assertTrue(fileio.exists(self._metadata_path))
      expected_execution_count = (
          9  # 7 components + 1 resolver + 1 importer
      )
      metadata_config = metadata.sqlite_metadata_connection_config(
          self._metadata_path
      )
      store = mlmd.MetadataStore(metadata_config)
      artifact_count = len(store.get_artifacts())
      execution_count = len(store.get_executions())
      self.assertGreaterEqual(artifact_count, execution_count)
      self.assertEqual(expected_execution_count, execution_count)
  
      self.assertPipelineExecution(has_schema_gen=False)
  
imports: import importlib
  import os
  from typing import List
  from absl import logging
  from absl.testing import parameterized
  import tensorflow
  from tfx.examples.penguin import penguin_pipeline_local
  from tfx.v1 import proto
  from tfx.v1.dsl.io import fileio
  from tfx.v1.orchestration import LocalDagRunner
  from tfx.v1.orchestration import metadata
  import ml_metadata
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 9 for calling the PenguinPipelineLocalEndToEndTest obj's underlying member method code with example usage: obj.testPenguinPipelineLocalWithImporter() without return types