From 9f949b0dbcb5f53edb60efc5da3295ae5649657a Mon Sep 17 00:00:00 2001 From: Fred Thomsen Date: Thu, 20 Jun 2024 22:08:59 -0500 Subject: [PATCH] Add comment regarding triggered dag xcom --- airflow/operators/trigger_dagrun.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/operators/trigger_dagrun.py b/airflow/operators/trigger_dagrun.py index cf3c65995fb50..19cc0562cc32a 100644 --- a/airflow/operators/trigger_dagrun.py +++ b/airflow/operators/trigger_dagrun.py @@ -223,6 +223,7 @@ def execute(self, context: Context): raise RuntimeError("The dag_run should be set here!") # Store the run id from the dag run (either created or found above) to # be used when creating the extra link on the webserver. + # TODO: Logical date as xcom stored only for backwards compatibility. Remove in Airflow 3.0 ti = context["task_instance"] ti.xcom_push(key=XCOM_LOGICAL_DATE_ISO, value=dag_run.logical_date.isoformat()) ti.xcom_push(key=XCOM_RUN_ID, value=dag_run.run_id)