code: def setUp(self):
      super().setUp()
      pipeline = pipeline_pb2.Pipeline()
      pipeline.pipeline_info.id = "pipeline"
      pipeline.nodes.add().pipeline_node.node_info.id = "Trainer"
      pipeline.nodes.add().pipeline_node.node_info.id = "Transform"
      importer_node = pipeline.nodes.add().pipeline_node
      importer_node.node_info.id = "Importer"
      importer_node.node_info.type.name = constants.IMPORTER_NODE_TYPE
      deployment_config = pipeline_pb2.IntermediateDeploymentConfig()
      executor_spec = pipeline_pb2.ExecutorSpec.PythonClassExecutorSpec(
          class_path="trainer.TrainerExecutor"
      )
      deployment_config.executor_specs["Trainer"].Pack(executor_spec)
      pipeline.deployment_config.Pack(deployment_config)
      self._spec_type_url = deployment_config.executor_specs[
          "Trainer"
      ].type_url
      self._pipeline = pipeline
      ts.TaskSchedulerRegistry.clear()
  
imports: from absl.testing.absltest import mock
  import tensorflow
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.core import constants
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.orchestration.experimental.core import test_utils
  from tfx.proto.orchestration import execution_result_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import test_case_utils
label_desc: Use image node_id 1 for calling the TaskSchedulerRegistryTest obj's underlying member method code with example usage: obj.setUp() without return types