I think Tal made good suggestions.  Just adding a few more ideas:
* In dag 1 you could add a task using ExternalTaskSensor  so that it waits
for dag 2 to complete.
* In dag 1 you could first check whether there is still a dag 2 running
(using either airflow API or querying the metastore like ExternalTaskSensor
does), and if so immediately raise AirflowSkipException.  Then dag 1 will
check again next time it runs.

Reply via email to