class_docstr: A task scheduler for Manual system node.
class_docstr_tok: ["A","task","scheduler","for","Manual","system","node","."]
code: def __init__(
      self,
      mlmd_handle: metadata.Metadata,
      pipeline: pipeline_pb2.Pipeline,
      task: task_lib.ExecNodeTask,
  ):
      super().__init__(mlmd_handle, pipeline, task)
      self._cancel = threading.Event()
      if task.cancel_type:
          self._cancel.set()
  
imports: import threading
  from typing import Optional
  import attr
  from tfx.orchestration import data_types_utils
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.core import mlmd_state
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import json_utils
  from tfx.utils import status
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 1 to create a new ManualTaskScheduler object from inherited base classes: task_scheduler.TaskScheduler with example: obj = ManualTaskScheduler(mlmd_handle, pipeline, task)