ComeçarComece gratuitamente

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

Ver Curso

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

Comece o exercício