code: def _register_task_schedulers() -> None:
      """Registers task schedulers."""
      ts.TaskSchedulerRegistry.register(
          "type.googleapis.com/tfx.orchestration.executable_spec.PythonClassExecutableSpec",
          kubernetes_task_scheduler.KubernetesTaskScheduler,
      )
      ts.TaskSchedulerRegistry.register(
          "type.googleapis.com/tfx.orchestration.executable_spec.BeamExecutableSpec",
          kubernetes_task_scheduler.KubernetesTaskScheduler,
      )
  
imports: from concurrent import futures
  import contextlib
  import time
  from absl import app
  from absl import flags
  from absl import logging
  import grpc
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator import kubernetes_task_scheduler
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service import kubernetes_orchestrator_service
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2_grpc
  from tfx.orchestration.experimental.core import event_observer
  from tfx.orchestration.experimental.core import pipeline_ops
  from tfx.orchestration.experimental.core import pipeline_state
  from tfx.orchestration.experimental.core import service_jobs
  from tfx.orchestration.experimental.core import task_manager
  from tfx.orchestration.experimental.core import task_queue
  from tfx.orchestration.experimental.core import task_scheduler
label_desc: Use image node_id 5 for calling a global function with example usage: _register_task_schedulers() without return types