How to run one airflow task and all its dependencies?

I suspected that

airflow run dag_id task_id execution_date

will run all upstream tasks, but it’s not. It will simply fail when it sees that not all dependent tasks are running. How to run a specific task and all its dependencies? I suppose this is not possible due to the decision of the airflow design, but is there any way around this?

+5
source share
1 answer

You can run the task yourself using the -i / -I / -A flags along with the run command.

But yes, the airflow design does not allow you to run a specific task and all its dependencies.

You can populate the dag by removing unnecessary tasks from the DAG for testing purposes

+4
source

Source: https://habr.com/ru/post/1265105/


All Articles