Retornando dados de uma função TaskFlow
Sua equipe armazena a configuração do pipeline em uma tarefa separada para que ela possa ser reutilizada nas etapas seguintes. Centralizar a configuração dessa forma é comum em produção: uma tarefa define as configurações e todas as outras leem os mesmos valores, em vez de codificá-los diretamente. A tarefa get_config já retorna o dicionário de configuração, e run_pipeline está pronto para usá-lo.
Este exercicio faz parte do curso
Criando Pipelines de Dados com Airflow
exercicio interativo prático
Transforme teoria em prática com um dos nossos exercicio interativos
Iniciar exercicio