Ao clicar para abrir minha DAG, recebo essa mensagem de erro:
minha DAG:
from airflow.models import DAG
from airflow.utils.dates import days_ago
from airflow.operators.empty import EmptyOperator
from airflow.operators.bash import BashOperator
with DAG(
'primeiro_dag',
start_date=days_ago(1),
schedule_interval='@daily'
) as dag:
tarefa1 = EmptyOperator(task_id='tarefa_1')
tarefa2 = EmptyOperator(task_id='tarefa_2')
tarefa3 = EmptyOperator(task_id='tarefa_3')
tarefa4 = BashOperator(
task_id='cria_pasta',
bash_command=r'mkdir -p "/home/airflow/pasta"'
)
tarefa1 >> [tarefa2, tarefa3]
tarefa3 >> tarefa4
Alguem teria uma sugestão por gentileza do que possa ser?
