class_docstr: CeleryKubernetesExecutor consists of CeleryExecutor and KubernetesExecutor.
  
  It chooses an executor to use based on the queue defined on the task.
  When the queue is the value of ``kubernetes_queue`` in section ``[celery_kubernetes_executor]``
  of the configuration (default value: `kubernetes`), KubernetesExecutor is selected to run the task,
  otherwise, CeleryExecutor is used.
class_docstr_tok: ["CeleryKubernetesExecutor","consists","of","CeleryExecutor","and","KubernetesExecutor",".","It","chooses","an","executor","to","use","based","on","the","queue","defined","on","the","task",".","When","the","queue","is","the","value","of","``","kubernetes_queue","``","in","section","``","[","celery_kubernetes_executor","]","``","of","the","configuration","(","default","value",":","`","kubernetes","`",")",",","KubernetesExecutor","is","selected","to","run","the","task",",","otherwise",",","CeleryExecutor","is","used","."]
docstr: Return either celery_executor or kubernetes_executor.
  
  :param simple_task_instance: SimpleTaskInstance
  :return: celery_executor or kubernetes_executor
docstr_tok: ["Return","either","celery_executor","or","kubernetes_executor",".",":","param","simple_task_instance",":","SimpleTaskInstance",":","return",":","celery_executor","or","kubernetes_executor"]
code: def _router(
      self, simple_task_instance: SimpleTaskInstance
  ) -> CeleryExecutor | KubernetesExecutor:
      """
      Return either celery_executor or kubernetes_executor.
  
      :param simple_task_instance: SimpleTaskInstance
      :return: celery_executor or kubernetes_executor
      """
      if simple_task_instance.queue == self.kubernetes_queue:
          return self.kubernetes_executor
      return self.celery_executor
  
imports: from __future__ import annotations
  from functools import cached_property
  from typing import TYPE_CHECKING, Sequence
  from airflow.configuration import conf
  from airflow.providers.celery.executors.celery_executor import CeleryExecutor
  from airflow.utils.log.logging_mixin import LoggingMixin
  from airflow.utils.providers_configuration_loader import providers_configuration_loaded
label_desc: Use image node_id 19 for calling the CeleryKubernetesExecutor obj's underlying member method code with example usage: obj._router(simple_task_instance) and returns: self, self