我试图在测试环境中使用多个任务来测试一个守护进程。我能够测试与dag关联的单个任务,但我希望在dag中创建多个任务,并启动第一个任务。用于测试我正在使用的dag中的一个任务。但是,当我在后台的下游有一个接一个的任务时,同样的情况就不起作用了。from airflow import DAG
from airflow.operators.bash_o
我使用"pip install 'apache- airflowstatsd‘安装了airflowstatsd,并安装了statsd_exporter。“ 例如,对于任务id为"task1“的dag id "dag1”,完成任务所用时间的度量是: airflow_dag_dag1_task1_duration。对于任务id为"task2“的dag id "<