class_docstr: Interface for task schedulers.
class_docstr_tok: ["Interface","for","task","schedulers","."]
docstr: Constructor.
  
  Args:
    mlmd_handle: A handle to the MLMD db.
    pipeline: The pipeline IR proto.
    task: Task to be executed.
docstr_tok: ["Constructor",".","Args",":","mlmd_handle",":","A","handle","to","the","MLMD","db",".","pipeline",":","The","pipeline","IR","proto",".","task",":","Task","to","be","executed","."]
code: def __init__(
      self,
      mlmd_handle: metadata.Metadata,
      pipeline: pipeline_pb2.Pipeline,
      task: _TaskT,
  ):
      """Constructor.
  
      Args:
        mlmd_handle: A handle to the MLMD db.
        pipeline: The pipeline IR proto.
        task: Task to be executed.
      """
      self.mlmd_handle = mlmd_handle
      self.pipeline = pipeline
      self.task = task
  
imports: import abc
  from typing import Callable, Dict, Generic, List, Optional, Type, TypeVar, Union
  import attr
  from tfx import types
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.core import task
  from tfx.proto.orchestration import execution_result_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import status
label_desc: Use image node_id 1 to create a new TaskScheduler object from inherited base classes: abc, Generic with example: obj = TaskScheduler(mlmd_handle, pipeline, task)