我使用的是最新版本的airflow (从1.10.6版开始,sentry与airflow集成在一起)。但是,我无法获得有关dag或任务状态的任何信息。我准备了一些简单的dag,可能会失败,但在放哨时我没有收到任何东西。建立连接是因为当我犯了一些打字错误,例如在导入时,错误信息是在哨兵处捕捉到的。在本例中,我使用了SequentialExecutor
from airflow imp
下面是iam的链接:Dynamic DAG creation in Apache airflow 下面是用于创建示例hello world动态DAGs的代码块(基于输入参数的动态DAG创建)。from datetime import datetime
from airflow.operators.python_operator importdefault_args)