这个问题通常发生在Airflow使用CeleryKubernetesExecutor作为执行器时,因为这个执行器缺少必要的方法。解决这个问题的一种方法是修改airflow.cfg文件,将执行器更改为KubernetesExecutor。具体来说,需要将executor参数设置为KubernetesExecutor,如下所示:
executor = KubernetesExecutor
然后,重新启动Airflow服务,问题应该就解决了。如果问题仍然存在,请尝试升级Airflow版本或查看有关此问题的更多信息的社区帖子。
下一篇:Airflow调度程序不断终止