code: def testRun(self, mock_publisher):
      mock_publisher.return_value.publish_execution.return_value = {}
  
      example_gen = FileBasedExampleGen(
          custom_executor_spec=executor_spec.ExecutorClassSpec(
              parquet_executor.Executor
          ),
          input_base=self.parquet_dir_path,
          input_config=self.input_config,
          output_config=self.output_config,
      ).with_id("ParquetExampleGen")
  
      output_data_dir = os.path.join(
          os.environ.get(
              "TEST_UNDECLARED_OUTPUTS_DIR", self.get_temp_dir()
          ),
          self._testMethodName,
      )
      pipeline_root = os.path.join(output_data_dir, "Test")
      fileio.makedirs(pipeline_root)
      pipeline_info = data_types.PipelineInfo(
          pipeline_name="Test",
          pipeline_root=pipeline_root,
          run_id="123",
      )
  
      driver_args = data_types.DriverArgs(enable_cache=True)
  
      connection_config = metadata_store_pb2.ConnectionConfig()
      connection_config.sqlite.SetInParent()
      metadata_connection = metadata.Metadata(connection_config)
  
      launcher = in_process_component_launcher.InProcessComponentLauncher.create(
          component=example_gen,
          pipeline_info=pipeline_info,
          driver_args=driver_args,
          metadata_connection=metadata_connection,
          beam_pipeline_args=[],
          additional_pipeline_args={},
      )
      self.assertEqual(
          launcher._component_info.component_type,
          name_utils.get_full_name(FileBasedExampleGen),
      )
  
      launcher.launch()
      mock_publisher.return_value.publish_execution.assert_called_once()
  
      # Check output paths.
      self.assertTrue(
          fileio.exists(os.path.join(pipeline_root, example_gen.id))
      )
  
file_path: tfx/tfx/components/example_gen/custom_executors/parquet_component_test.py
imports: import os
  from unittest import mock
  import tensorflow
  from tfx.components.example_gen.component import FileBasedExampleGen
  from tfx.components.example_gen.custom_executors import parquet_executor
  from tfx.dsl.components.base import executor_spec
  from tfx.dsl.io import fileio
  from tfx.orchestration import data_types
  from tfx.orchestration import metadata
  from tfx.orchestration import publisher
  from tfx.orchestration.launcher import in_process_component_launcher
  from tfx.proto import example_gen_pb2
  from tfx.utils import name_utils
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling the ExampleGenComponentWithParquetExecutorTest obj's underlying member method code with example usage: obj.testRun(mock_publisher) without return types