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
