小编Wei*_*Hao的帖子

气流depends_on_past说明

根据官方的Airflow文档,需要处于成功状态的task instances直接上游task。另外,如果您设置了depends_on_past = True,则前一个任务实例需要成功(除非它是该任务的第一次运行)。

众所周知,任务是一种“实例化和参数化”的运算符。

现在,这让我感到困惑。例如:

DAG: {op_1} -> {op_2} -> {op_3}
Run Code Online (Sandbox Code Playgroud)

{op_2}是一个简单的PythonOperator,它从{op_1}获取1个参数并执行操作;

据我了解,op_2(param_1)和op_2(param_2)被视为2个不同的任务。

Given depends_on_past设置为True,则:

  1. 如果op_2(param_1)仍在运行;可以运行op_2(param_2)吗?
  2. 如果op_2(param_1)在上一次运行中失败;可以在当前运行中运行op_2(param_1)吗?

python python-3.x airflow

8
推荐指数
1
解决办法
4344
查看次数

标签 统计

airflow ×1

python ×1

python-3.x ×1