class_docstr: Implementation of Kubernetes Task Scheduler.
class_docstr_tok: ["Implementation","of","Kubernetes","Task","Scheduler","."]
code: def cancel(self, cancel_task: task_lib.CancelTask) -> None:
      # TODO(b/240237394): implement method.
      pass
  
file_path: tfx/tfx/orchestration/experimental/centralized_kubernetes_orchestrator/kubernetes_task_scheduler.py
imports: import threading
  from tfx.orchestration import data_types_utils
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator import kubernetes_job_runner
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.orchestration.portable import data_types
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import execution_invocation_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import status
label_desc: Use image node_id 3 for calling the KubernetesTaskScheduler obj's underlying member method code with example usage: obj.cancel(cancel_task) without return types