Copiei o código exatamente assim:
from airflow.models import DAG
from airflow.utils.dates import days_ago
from airflow.operators.empty import EmptyOperator
from airflow.operators.bash_operator import BashOperator
with DAG(
'meu_primeiro_dag',
start_date=days_ago(2),
schedule_interval='@daily'
) as dag:
tarefa_1 = EmptyOperator(task_id = 'tarefa_1')
tarefa_2 = EmptyOperator(task_id = 'tarefa_2')
tarefa_3 = EmptyOperator(task_id = 'tarefa_3')
tarefa_4 = BashOperator(
task_id = 'cria_pasta',
bash_command = 'mkdir -p "home/millenagena/Documents/airflowalura/pasta={{data_interval_end}}" '
)
tarefa_1 >> [tarefa_2, tarefa_3]
tarefa_3 >> tarefa_4
**
Executei na mesma ordem apresentada no vídeo, criei ativei o ambiente virtual, exclui e depois executei o novo DAG, mas só executou para 1 dia atrás e não 2 como deveria acontecer.
**