From 75fb46023f01b17d04cceb073f2e002ad184bd79 Mon Sep 17 00:00:00 2001 From: Jakub Matyszewski Date: Tue, 5 May 2026 13:11:12 +0300 Subject: [PATCH] Fix None-valued OTel span attributes in triggerer --- .../src/airflow/jobs/triggerer_job_runner.py | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/airflow-core/src/airflow/jobs/triggerer_job_runner.py b/airflow-core/src/airflow/jobs/triggerer_job_runner.py index 9a22e61ad8a03..727b4b9f37e2e 100644 --- a/airflow-core/src/airflow/jobs/triggerer_job_runner.py +++ b/airflow-core/src/airflow/jobs/triggerer_job_runner.py @@ -131,11 +131,17 @@ def _make_trigger_span( span_name += f"_{ti.map_index}" attributes = { **attributes, - "airflow.dag_id": ti.dag_id, - "airflow.task_id": ti.task_id, - "airflow.dag_run.run_id": ti.run_id, - "airflow.task_instance.try_number": ti.try_number, - "airflow.task_instance.map_index": ti.map_index, + **{ + k: v + for k, v in { + "airflow.dag_id": ti.dag_id, + "airflow.task_id": ti.task_id, + "airflow.dag_run.run_id": ti.run_id, + "airflow.task_instance.try_number": ti.try_number, + "airflow.task_instance.map_index": ti.map_index, + }.items() + if v is not None + }, } else: span_name = f"trigger.{name}"