This is an automated email from the ASF dual-hosted git repository. uranusjr pushed a commit to branch aip-39-docs in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 35232d8028140606d49db2cb595c9583ef35dd87 Author: Tzu-ping Chung <[email protected]> AuthorDate: Mon Sep 13 15:19:16 2021 +0800 Revert TI.xcom_pull() usage We need to use execution_date here :/ --- airflow/models/taskinstance.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index 5120f59..2a74bde 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -2258,8 +2258,10 @@ class TaskInstance(Base, LoggingMixin): if dag_id is None: dag_id = self.dag_id + execution_date = self.get_dagrun(session).execution_date + query = XCom.get_many( - run_id=self.run_id, + execution_date=execution_date, key=key, dag_ids=dag_id, task_ids=task_ids,
