code: def setUp(self):
      super().setUp()
  
      self.addCleanup(mock.patch.stopall)
      # Set a constant version for artifact version tag.
      mock.patch("tfx.version.__version__", "0.123.4.dev").start()
  
      pipeline_root = os.path.join(
          os.environ.get(
              "TEST_UNDECLARED_OUTPUTS_DIR", self.get_temp_dir()
          ),
          self.id(),
      )
  
      metadata_path = os.path.join(
          pipeline_root, "metadata", "metadata.db"
      )
      self._mlmd_cm = mlmd_cm.MLMDConnectionManager.sqlite(
          metadata_path
      )
      self.enter_context(self._mlmd_cm)
      self._mlmd_connection = self._mlmd_cm.primary_mlmd_handle
  
      pipeline = self._make_pipeline(pipeline_root, str(uuid.uuid4()))
      self._pipeline = pipeline
      self._importer_node = self._pipeline.nodes[0].pipeline_node
  
      self._task_queue = tq.TaskQueue()
      [importer_task] = test_utils.run_generator_and_test(
          test_case=self,
          mlmd_connection_manager=self._mlmd_cm,
          generator_class=sptg.SyncPipelineTaskGenerator,
          pipeline=self._pipeline,
          task_queue=self._task_queue,
          use_task_queue=True,
          service_job_manager=None,
          num_initial_executions=0,
          num_tasks_generated=1,
          num_new_executions=1,
          num_active_executions=1,
          expected_exec_nodes=[self._importer_node],
          ignore_update_node_state_tasks=True,
      )
      self._importer_task = importer_task
  
imports: import os
  from unittest import mock
  import uuid
  import tensorflow
  from tfx.dsl.compiler import constants
  from tfx.orchestration.experimental.core import post_execution_utils
  from tfx.orchestration.experimental.core import sync_pipeline_task_gen
  from tfx.orchestration.experimental.core import task_queue
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.orchestration.experimental.core import test_utils
  from tfx.orchestration.experimental.core.task_schedulers import importer_task_scheduler
  from tfx.orchestration.experimental.core.testing import test_pipeline_with_importer
  from tfx.orchestration import mlmd_connection_manager
  from tfx.orchestration.portable import runtime_parameter_utils
  from tfx.utils import status
label_desc: Use image node_id 1 for calling the ImporterTaskSchedulerTest obj's underlying member method code with example usage: obj.setUp() without return types