我的Cloud Composer 托管Airflow 卡住了几个小时，因为我取消了一个耗时太长的任务实例（我们称之为任务 A）
我已清除所有 DAG 运行和任务实例，但有一些作业正在运行，还有一个作业处于关闭状态（我想是任务 A 的作业）(snapshot of my Jobs)。
此外，调度程序似乎从recently deleted DAGs keep appearing in the dashboard开始就没有运行
有没有办法杀死作业或重置调度程序？任何能让作曲家解脱的想法都将受到欢迎。
【问题讨论】：
标签： google-cloud-platform airflow google-cloud-composer
您可以按如下方式重新启动调度程序：
从您的云外壳：
1.确定您环境的 Kubernetes 集群：
gcloud composer environments describe ENVIRONMENT_NAME \
--location LOCATION
2.获取凭据并连接到 Kubernetes 集群：
gcloud container clusters get-credentials ${GKE_CLUSTER} --zone ${GKE_LOCATION}
3.运行以下命令重启调度器：
kubectl get deployment airflow-scheduler -o yaml | kubectl replace --force -f -
第 1 步和第 2 步的详细信息here。第 3 步基本上将“airflow-scheduler”部署替换为自身，从而重新启动服务。
如果重新启动调度程序没有帮助，您可能还需要重新创建 Composer 环境并在每次都发生这种情况时对 DAG 进行故障排除。
【讨论】：
airflow-scheduler Pod，这将导致 Kubernetes 将其替换为新的。
您正在运行哪个版本的 Composer？这是一个已知问题，工作可能会因测试版而卡住。 Composer 1.0.0 和 1.1.0 应该不会看到任何卡住的作业（SubDag 中的任务除外，这是一个已知的 Airflow 错误），请考虑迁移到最新的 Composer version。
【讨论】：