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}"