Skip to content

Commit

Permalink
Add comment regarding triggered dag xcom
Browse files Browse the repository at this point in the history
  • Loading branch information
fredthomsen committed Jun 21, 2024
1 parent d1204ad commit 9f949b0
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions airflow/operators/trigger_dagrun.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 9f949b0

Please sign in to comment.