quando eu acesso para verificar a criação da dag aparece esse erro.
Broken DAG: [/home/matheus/Documents/airflowalura/dags/meu_primeiro_dag.py] Traceback (most recent call last): File "", line 228, in callwith_frames_removed File "/home/matheus/Documents/airflowalura/dags/meu_primeiro_dag.py", line 7, in with DAG( TypeError: init() got an unexpected keyword argument 'scheule_interval'
Meu código está 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(1), scheule_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/matheus/Documents/airflowalura/pasta" '
)
tarefa_1 >> [tarefa_2, tarefa_3]
tarefa_3 >> tarefa_4
