未调用气流集群策略

Question

我正在尝试设置和理解自定义策略。不确定我做错了什么，但是，按照这个行不通。

气流版本：1.10.10

预期结果： 如果我尝试使用 default_owner

运行 DAG，它应该抛出异常

实际结果：没有这样的异常

/root/airflow/config/airflow_local_settings.py

class PolicyError(Exception):
    pass


def cluster_policy(task):
    print("task_instance_mutation_hook")
    raise PolicyError


def task_instance_mutation_hook(ti):
    print("task_instance_mutation_hook")
    raise PolicyError

• /root/airflow/config/airflow_local_settings.pyc 文件正在创建，所以我知道这个文件正在被气流处理。
• 如果这个文件中有任何编译错误，我的所有 dags 都会失败。但是上面的文件没有。

不确定我做错了什么。

Answer 1

此功能仅适用于 1.10.12 版本。