KubernetesExecutor single task run error: Only works with the Celery or Kubernetes executors, sorry #12341
Labels
area:webserver
Webserver related Issues
kind:bug
This is a clearly a bug
provider:cncf-kubernetes
Kubernetes provider related issues
Milestone
Apache Airflow version: 1.10.12
Kubernetes version (if you are using kubernetes) (use kubectl version): v1.16.13-gke.401
Environment: AWS EKS
What happened:
Hi Airflow community ✋ I have detected bug on Airflow webserver. I have deployed Airflow cluster that uses Kubernetes executor, runs on production AWS EKS cluster. All configurations are correct and runs successfully tasks on DAGs. But when I want to run specific task on DAG, that throws error like that:
But, I have checked my KubernetesExecutor configurations all of them are correct. So, I have digged error on source code of Airflow webserver at tag 1.10.12 which I have deployed version of Airflow. And found that some import errors are ignored for KubernetesExecutor on file https://github.com/apache/airflow/blob/1.10.12/airflow/www/views.py at line 1152
In there, bug in this code snippet
Import statement raises error KubernetesExecutor not found in this module because when you look that module at tag 1.10.12 https://github.com/apache/airflow/blob/1.10.12/airflow/contrib/executors/kubernetes_executor.py, there is no KubernetesExecutor class, only includes kubernetes_executor module which it is KubernetesExecutor's location. But when you use that you need to change the code like that:
or:
What you expected:
Runs successfully single task with KubernetesExecutor. This error block user to run single task with KubernetesExecutor without run whole DAG.
Thanks, have a nice day 👍 😄
The text was updated successfully, but these errors were encountered: