Implicações do executor
Você está aprendendo bastante sobre a execução do Airflow DAGs e está ganhando confiança no desenvolvimento de novos fluxos de trabalho. Dito isso, seu gerente mencionou que, em alguns dias, os fluxos de trabalho estão demorando muito mais para serem concluídos e pediu que você investigasse. Ela também menciona que o arquivo salesdata_ready.csv
está demorando mais para ser gerado atualmente e que a hora do dia em que ele é concluído é variável.
Este exercício requer informações das duas lições anteriores - lembre-se das implicações dos argumentos disponíveis e modifique o fluxo de trabalho de acordo. Observe que, para este exercício, espera-se que você modifique uma linha de código, não adicione nenhum código extra.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções de exercício
- Determine o nível de paralelismo disponível nesse sistema. Você pode fazer isso verificando a configuração do fluxo de ar (você pode executar
airflow info
no terminal). - Consulte a fonte do arquivo DAG e corrija a entrada que está causando o problema.
Exercício interativo prático
Transforme a teoria em ação com um de nossos exercícios interativos
