Perguntas com a marcação «airflow-scheduler»

O planejador de fluxo de ar falha ao iniciar com o executor kubernetes

Estou usando o https://github.com/helm/charts/tree/master/stable/airflow helm chart e construindo a puckle/docker-airflowimagem v1.10.8 com o kubernetes instalado e usando essa imagem no gráfico de helm, mas continuo recebendo File "/usr/local/bin/airflow", line 37, in <module>...

Como acionar uma tarefa Airflow somente quando novas partições / dados estão disponíveis na tabela AWS athena usando o DAG em python?

Eu tenho um cenário como abaixo: Acione um Task 1e Task 2somente quando novos dados estiverem disponíveis para eles na tabela de origem (Athena). O acionador da Tarefa1 e da Tarefa2 deve ocorrer quando uma nova parição de dados em um dia. Disparar Task 3apenas após a conclusão Task 1eTask...