小编use*_*397的帖子

气流在单个DAG中生成动态任务,任务N + 1取决于TaskN

动态生成任务时,我需要让Task 2依赖于Task 1,Task1 >> Task 2或task2.set_upstream(task1)。

由于task_ids已评估,或者似乎是预先确定的,因此我无法提前设置依赖关系,将不胜感激。

Component(I)任务可以很好地运行,只不过它们一次运行即可。

for i in range(1,10):
  task_id='Component'+str(i)
  task_id = BashOperator(
  task_id='Component'+str(i),
  bash_command="echo  {{ ti.xcom_pull task_ids='SomeOtherTaskXcom', key='return_value') }} -z " + str(i) ,
  xcom_push=True,
  dag=dag) 
  ?????.set_upstream(??????)
Run Code Online (Sandbox Code Playgroud)

python airflow

4
推荐指数
2
解决办法
1256
查看次数

标签 统计

airflow ×1

python ×1