class_docstr: A task scheduler for Importer system node.
class_docstr_tok: ["A","task","scheduler","for","Importer","system","node","."]
code: def schedule(self) -> task_scheduler.TaskSchedulerResult:
      pipeline_node = self.task.get_node()
      output_key = cast(
          str, self.task.exec_properties[importer.OUTPUT_KEY_KEY]
      )
      output_spec = pipeline_node.outputs.outputs[output_key]
      properties = data_types_utils.build_parsed_value_dict(
          output_spec.artifact_spec.additional_properties
      )
      custom_properties = data_types_utils.build_parsed_value_dict(
          output_spec.artifact_spec.additional_custom_properties
      )
  
      output_artifacts = importer.generate_output_dict(
          metadata_handle=self.mlmd_handle,
          uri=cast(
              str, self.task.exec_properties[importer.SOURCE_URI_KEY]
          ),
          properties=properties,
          custom_properties=custom_properties,
          reimport=bool(
              self.task.exec_properties[importer.REIMPORT_OPTION_KEY]
          ),
          output_artifact_class=types.Artifact(
              output_spec.artifact_spec.type
          ).type,
          mlmd_artifact_type=output_spec.artifact_spec.type,
          output_key=output_key,
      )
  
      return task_scheduler.TaskSchedulerResult(
          status=status_lib.Status(code=status_lib.Code.OK),
          output=task_scheduler.ImporterNodeOutput(
              output_artifacts=output_artifacts
          ),
      )
  
file_path: tfx/tfx/orchestration/experimental/core/task_schedulers/importer_task_scheduler.py
imports: from typing import cast
  from tfx import types
  from tfx.dsl.components.common import importer
  from tfx.orchestration import data_types_utils
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.utils import status
label_desc: Use image node_id 1 for calling the ImporterTaskScheduler obj's underlying member method code with example usage: obj.schedule() and returns: task_scheduler