我创建了一个DAG，并在默认参数中将自己指定为DAG所有者。但自从它开始它显示了两个业主“我自己”，“气流”。为什么气流中会有这种奇怪的现象。无法找出根本原因。请咨询。
7kqas0il1#
在Airflow中，您可以在任务级别设置所有者：
EmpyOperator(task_id="task1", owner="owner1") EmpyOperator(task_id="task2", owner="owner2")
字符串在DAG级别，所有者是属性聚合与此DAG关联的所有任务的所有者。你可以在源代码中看到它。因此：
with DAG(dag_id="my_dag", ...): EmpyOperator(task_id="task1", owner="owner1") EmpyOperator(task_id="task2", owner="owner2")
型将有两个主人：第一个月通常情况下，通过default_args设置owner是很常见的：
default_args = { 'owner': 'some_owner', } with DAG(dag_id="my_dag", default_args=default_args, ...): EmpyOperator(task_id="task1") EmpyOperator(task_id="task2")
型在这种情况下，不需要在任务级别上处理设置所有者，并且具有此DAG的所有任务都将具有相同的所有者。
1条答案
按热度按时间7kqas0il1#
在Airflow中，您可以在任务级别设置所有者：
字符串
在DAG级别，所有者是属性聚合与此DAG关联的所有任务的所有者。你可以在源代码中看到它。
因此：
型
将有两个主人：第一个月
通常情况下，通过default_args设置owner是很常见的：
型
在这种情况下，不需要在任务级别上处理设置所有者，并且具有此DAG的所有任务都将具有相同的所有者。