3
我有一個task_a,我想在DAG_1和DAG_2中使用。這是可能的氣流?在氣流中是否可以在多個DAGS中使用單個任務?
task_a = SomeOperator(
task_id='some_id',
bash_command='some_command',
#instead of just
dag= DAG_1 # I want to assign this task to multiple dags
#dag=assign_multiple_dags_here(DAG_1 and DAG_2)
)
這可能嗎?
我提出了你的建議使用部分。我喜歡它作爲解決方法。 – javed