apache/airflow

Log exceptions as warnings till the final attempt

Aberta

#32.246 aberto em 28 de jun. de 2023

Ver no GitHubGuia do colaborador
 (10 comentários) (1 reação) (0 responsável)Python (16.781 forks)batch import
good first issuekind:feature

Métricas do repositório

Stars
 (44.809 estrelas)
Métricas de merge de PR
 (Métricas PR pendentes)

Description

Description

We have an integration with sentry on Google cloud composer. We would like to be alerted for any exceptions happening in airflow , but don't want to be alerted when those exceptions would be retried. We tried setting alert conditions on number of errors, but it does not solve the problem as we have hundreds of instances of a DAG running.

Requirements:

  1. Log as warning when try_number is less than equal to max_tries.
  2. Log as an error in the final try.

Use case/motivation

No response

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Guia do colaborador

Direção de pesquisa
Investigue o fluxo de execução da instância de tarefa no Airflow, especificamente o mecanismo de registro em `airflow/models/taskinstance.py`. Observe como `try number` e `max tries` são rastreados e onde as exceções são registradas. A alteração provavelmente envolve modificar o nível de registro com base se a tentativa atual é a retentativa final. Verifique as chamadas de registro existentes nos métodos ` execute task` ou similares e considere usar `logging.Logger.warning` para tentativas não finais e `logging.Logger.error` para a tentativa final.
Pilha de tecnologia
python
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
1-2 dias
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
PythonAirflow
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
70