This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-9-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 6d183e7d1aa2bcab966d2152e58752b255cf4606 Author: Andrey Anshin <[email protected]> AuthorDate: Tue Apr 30 22:30:59 2024 +0400 Do not provide deprecated `execution_date` in `@apply_lineage` (#39327) (cherry picked from commit 10e34d348e15666a7d231bfbca2d1ffd555e7c63) --- airflow/lineage/__init__.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/airflow/lineage/__init__.py b/airflow/lineage/__init__.py index 1ca6ad0604..6500d8008e 100644 --- a/airflow/lineage/__init__.py +++ b/airflow/lineage/__init__.py @@ -82,14 +82,10 @@ def apply_lineage(func: T) -> T: inlets = list(self.inlets) if outlets: - self.xcom_push( - context, key=PIPELINE_OUTLETS, value=outlets, execution_date=context["ti"].execution_date - ) + self.xcom_push(context, key=PIPELINE_OUTLETS, value=outlets) if inlets: - self.xcom_push( - context, key=PIPELINE_INLETS, value=inlets, execution_date=context["ti"].execution_date - ) + self.xcom_push(context, key=PIPELINE_INLETS, value=inlets) if _backend: _backend.send_lineage(operator=self, inlets=self.inlets, outlets=self.outlets, context=context)
