apache/airflow

`StackdriverTaskHandler` rework for the structlog era

Fermée

#65 191 ouverte le 14 avr. 2026

Voir sur GitHubGuide contributeur
 (0 commentaire) (0 réaction) (0 personne assignée)Python (16 781 forks)batch import
area:loggingarea:providersgood first issuekind:metaprovider:google

Métriques du dépôt

Stars
 (44 809 étoiles)
Métriques de merge PR
 (Merge moyen 7j 18h) (834 PRs mergées en 30 j)

Description

Body

Following https://github.com/apache/airflow/pull/48491

Reference: https://github.com/apache/airflow/pull/48788

In Airflow 3, the task execution path was rearchitected: task workers now use structlog and communicate with a RemoteLogIO (set as REMOTE_TASK_LOGin the logging config module) rather than through a Python stdlib logging. Handler registered inDEFAULT_LOGGING_CONFIG`.

All major remote log backends have been migrated to this new pattern — S3, GCS, CloudWatch, WASB, OSS, HDFS (recently in #48788), and Elasticsearch. Similar effort is needed for StackDriver

Committer

  • I acknowledge that I am a maintainer/committer of the Apache Airflow project.

Guide contributeur

Direction de recherche
Examine the referenced PRs (#48491, #48788) to understand the pattern used for migrating remote log backends to structlog. Implement the same changes for the StackDriverTaskHandler, likely located in airflow/providers/google/cloud/logging/stackdriver task handler.py. Ensure the handler uses the RemoteLogIO interface and structlog instead of the stdlib logging handler. Follow the structure of similar migrated handlers such as S3 or GCS.
Stack technique
pythongcp
Domaine
backendinfrastructureobservabilitycloud
Type d'issue
Refactorisation
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
3
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
1-2 jours
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Récente
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Claire
Prérequis
Familiarity with Airflow loggingUnderstanding of structlogKnowledge of StackDriver
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
50