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.
- Can airflow tracks each dag run based on arguments passed ... Vishu Murundi
- RE: Can airflow tracks each dag run based on argument... Tal Nagar
- Re: Can airflow tracks each dag run based on argu... Daniel Standish
- Re: Can airflow tracks each dag run based on ... Vishu Murundi
