You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Song Yikun (Jira)" <ji...@apache.org> on 2020/02/17 08:38:00 UTC
[jira] [Commented] (AIRFLOW-1825) Set Multi dag dependency
[ https://issues.apache.org/jira/browse/AIRFLOW-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038155#comment-17038155 ]
Song Yikun commented on AIRFLOW-1825:
-------------------------------------
Not sure this is still relevant (otherwise it should be closed?), I think this could be achieved by just two sequential ExternalTaskSensors? `wait_dag_a` and followed by `wait_dag_b`, or schedule them both as upstream relative to DAG C.
i.e.
wait_dag_a >> wait_dag_b >> dag_c
(note the order does not matter because you need both)
wait_dag_a >> dag_c
wait_dag_b >> dag_c
There should not be a lot of `overhead` mentioned above if you use relative big DAG, otherwise, it might be a good idea to concatenate your DAGs.
> Set Multi dag dependency
> -------------------------
>
> Key: AIRFLOW-1825
> URL: https://issues.apache.org/jira/browse/AIRFLOW-1825
> Project: Apache Airflow
> Issue Type: Task
> Reporter: Snigdha Nair
> Priority: Major
>
> I have 3 dags A, B and C. Dag C should get triggered only after tasks in dag A and B completes. Is there a way to implement this in airflow? I am able to set dependency between dag A and C using Triggerdagrun Operator. But when I try to set dependency between dag B and C, C is getting triggered when either A or B completes. Can someone please help me in solving this? I understand that explains external task sensor Operator can be used. But it continuously polls if task in dag A and B is complete which might create performance hit over a period of time.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)