小编bre*_*dan的帖子

在气流中,有没有很好的方法来调用另一个dag的任务?

我有dag_prime和dag_tertiary。

  • dag_prime:扫描目录,并打算在每个目录上调用dag_tertiary。目前是PythonOperator。
  • dag_tertiary:浏览传递给它的目录,并对其内容进行(可能很耗时)计算。

我可以从python运算符的系统调用中调用第二个,但我觉得必须有更好的方法。如果有一种简单的方法,我还想考虑对dag_tertiary调用进行排队。有没有比使用系统调用更好的方法?

谢谢!

airflow apache-airflow

3
推荐指数
1
解决办法
7885
查看次数

标签 统计

airflow ×1

apache-airflow ×1