code: def testLauncher_importer_mode_reimport_enabled(self):
      handler = importer_node_handler.ImporterNodeHandler()
      execution_info = handler.run(
          mlmd_connection=self._mlmd_connection,
          pipeline_node=self._importer,
          pipeline_info=self._pipeline_info,
          pipeline_runtime_spec=self._pipeline_runtime_spec,
      )
  
      with self._mlmd_connection as m:
          [artifact] = m.store.get_artifacts_by_type("Schema")
          self.assertProtoPartiallyEquals(
              """
            id: 1
            uri: "my_url"
            custom_properties {
              key: "int_custom_property"
              value {
                int_value: 123
              }
            }
            custom_properties {
              key: "is_external"
              value {
                int_value: 1
              }
            }
            custom_properties {
              key: "str_custom_property"
              value {
                string_value: "abc"
              }
            }
            custom_properties {
              key: "tfx_version"
              value {
                string_value: "0.123.4.dev"
              }
            }
            state: LIVE""",
              artifact,
              ignored_fields=[
                  "type_id",
                  "type",
                  "create_time_since_epoch",
                  "last_update_time_since_epoch",
              ],
          )
          [execution] = m.store.get_executions_by_id(
              [execution_info.execution_id]
          )
          self.assertProtoPartiallyEquals(
              """
            id: 1
            last_known_state: COMPLETE
            custom_properties {
              key: "artifact_uri"
              value {
                string_value: "my_url"
              }
            }
            custom_properties {
              key: "output_key"
              value {
                string_value: "result"
              }
            }
            custom_properties {
              key: "reimport"
              value {
                int_value: 1
              }
            }
            """,
              execution,
              ignored_fields=[
                  "type_id",
                  "type",
                  "create_time_since_epoch",
                  "last_update_time_since_epoch",
                  "name",
              ],
          )
  
      execution_info = handler.run(
          mlmd_connection=self._mlmd_connection,
          pipeline_node=self._importer,
          pipeline_info=self._pipeline_info,
          pipeline_runtime_spec=self._pipeline_runtime_spec,
      )
      with self._mlmd_connection as m:
          new_artifact = m.store.get_artifacts_by_type("Schema")[1]
          self.assertProtoPartiallyEquals(
              """
            id: 2
            uri: "my_url"
            custom_properties {
              key: "int_custom_property"
              value {
                int_value: 123
              }
            }
            custom_properties {
              key: "is_external"
              value {
                int_value: 1
              }
            }
            custom_properties {
              key: "str_custom_property"
              value {
                string_value: "abc"
              }
            }
            custom_properties {
              key: "tfx_version"
              value {
                string_value: "0.123.4.dev"
              }
            }
            state: LIVE""",
              new_artifact,
              ignored_fields=[
                  "type_id",
                  "type",
                  "create_time_since_epoch",
                  "last_update_time_since_epoch",
              ],
          )
          [execution] = m.store.get_executions_by_id(
              [execution_info.execution_id]
          )
          self.assertProtoPartiallyEquals(
              """
            id: 2
            last_known_state: COMPLETE
            custom_properties {
              key: "artifact_uri"
              value {
                string_value: "my_url"
              }
            }
            custom_properties {
              key: "output_key"
              value {
                string_value: "result"
              }
            }
            custom_properties {
              key: "reimport"
              value {
                int_value: 1
              }
            }
            """,
              execution,
              ignored_fields=[
                  "type_id",
                  "type",
                  "create_time_since_epoch",
                  "last_update_time_since_epoch",
                  "name",
              ],
          )
  
file_path: tfx/tfx/orchestration/portable/importer_node_handler_test.py
imports: import os
  import tensorflow
  from tfx import version
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.portable import importer_node_handler
  from tfx.orchestration.portable import runtime_parameter_utils
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import test_case_utils
label_desc: Use image node_id 2 for calling the ImporterNodeHandlerTest obj's underlying member method code with example usage: obj.testLauncher_importer_mode_reimport_enabled() without return types