Oiii, queria uma ajuda.
Eu fiz tudo que precisava, mas ainda continuo sem conseguir fazer com que o DAG apareça no Airflow como no exercício. Eu faço tudo - e até substituí o days_ago por pendulum adicionando o local e o timezone como pedido, aprendi a chamar a função sozinho em baixo.. showw, maass: ainda nada.
from airflow.models import DAG
from airflow.utils.timezone import pendulum
from airflow.operators.empty import EmptyOperator
from airflow.operators.bash import BashOperator
local_tz = pendulum.timezone("America/Sao_Paulo")
with DAG(
'meu_primeiro_dag',
start_date=pendulum.today('UTC').add(days=-1).replace(tzinfo=local_tz),
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 /igorrodrigues/Documents/airflowalura/pasta",
)
tarefa_1 >> [tarefa_2, tarefa_3]
tarefa_3 >> [tarefa_4]
Ele aparece o seguintes erros:
Alguma ideia do que pode ser? O que estou errando?
Eu tentei:
1) Mudar esse days_ago para pendulum e chamar em baixo da forma correta (pedi ajuda ao chatGPT, rsrsrs)
2) Chequei para ver se a pasta que estava pedindo para enviar era a mesma em que estava o airflow (aparentemente está eu até dupliquei sem querer a pasta lá pra dentro e mesmo depois de colocar a pasta em DOCUMENTS certinho, ainda nada.
3) Refatorei e refiz a linha onde coloco a priorização das tarefas.
Será que pode ser porque tem o EmptyOperator e ele tá vazio mesmo? Era para ter alguma coisa? Mas eu vou exatamente até onde vai o exercício então não faria sentido.
Obrigadaço pela ajuda!
