动态生成任务时,我需要让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)