1
resposta

[Sugestão] Correções para versões mais recentes

Olá, estou utilizando a versão 3.1.7 do airflow com o python 3.12, e precisei fazer as seguintes alterações:

Ao instalar a biblioteca do airflow, dive que passar os seguintes parâmetros:

pip install 'apache-airflow==3.1.7' --constraint "https://raw.githubusercontent.com/apache/airflow/constraints-3.1.7/constraints-3.12.txt"

E o código python da DAG precisou ser atualizado também, da seguinte forma:

from airflow.models import DAG
import pendulum
from airflow.operators.empty import EmptyOperator
from airflow.operators.bash import BashOperator

with DAG(
    'meu_primeiro_dag',
    start_date = pendulum.today('UTC').add(days=-1),
    schedule='@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 "/opt/airflow"'
    )

    tarefa_1 >> [tarefa_2, tarefa_3]
    tarefa_3 >> tarefa_4
1 resposta

Oi, André! Como vai?

Agradeço por compartilhar essa dica no fórum! Com certeza ajudará outros alunos.

Continue explorando e testando diferentes versões das bibliotecas, isso fortalece muito o aprendizado em ferramentas de dados. ✨

Conte com o apoio do Fórum na sua jornada. Abraços e bons estudos!

Para saber mais:

Sugestão de conteúdo:

Alura Conte com o apoio da comunidade Alura na sua jornada. Abraços e bons estudos!