时间戳

首页 > 解决方案 > 气流任务实例突变未处理

airflow - 气流任务实例突变未处理

问题描述

我正在尝试设置和理解自定义策略，更具体地讲如何在执行之前改变任务。但是，不确定我做错了什么，这不起作用。

气流版本：1.10.12

预期结果：retry_number => 1 时应该修改队列

实际结果：什么都没有，队列永远不会改变

/root/airflow/config/airflow_local_settings.py

def task_instance_mutation_hook(task_instance: TaskInstance):
    if task_instance.try_number >= 1:
        task_instance.queue = 'retry_queue'

正在创建 /root/airflow/config/airflow_local_settings.py 文件，因此我知道该文件正在由气流处理，并且我可以看到该文件实际上已加载到调度程序日志中。

当我触发带有多次重试失败的任务的 DAG 时，在 UI 中检查任务实例详细信息时不会修改队列。

我正在使用 SequentialExecutor 开发 docker 堆栈，不知道这是否重要。

谢谢您的帮助

标签： airflowairflow-schedulermutation

解决方案

推荐阅读