小编Mik*_*ail的帖子

ExternalTaskSensor我里面有 DAG 。我正确设置execution_delta并且一切正常，除非我想手动运行该 DAG。我的ExternalTaskSensor状态正在运行，并且在timeout间隔之后失败，出现异常airflow.exceptions.AirflowSensorTimeout：Snap。时间到了。

我知道运行它的方法 - 在手动触发 DAG 之后，将ExternalTaskSensorDAG 中的每个设置为 Web 界面中的状态success。

但是，手动运行它而不将ExternalTaskSensorDAG 中的每个设置为的更好方法是吗success？

如何在气流中添加管理员用户？

我想使用简单的Web 身份验证。如果我按照文档airflow.apache.ort/security 中的描述添加用户，则用户不是管理员。

来自文档的代码：

import airflow
from airflow import models, settings
from airflow.contrib.auth.backends.password_auth import PasswordUser
user = PasswordUser(models.User())
user.username = 'new_user_name'
user.email = 'new_user_email@example.com'
user.password = 'set_the_password'
session = settings.Session()
session.add(user)
session.commit()
session.close()
exit()