Do not provide deprecated execution_date in @apply_lineage (#39327)

(cherry picked from commit 10e34d3)
apache · Jun 4, 2024 · 6d183e7 · 6d183e7
1 parent de98856
commit 6d183e7
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/airflow/lineage/__init__.py b/airflow/lineage/__init__.py
@@ -82,14 +82,10 @@ def wrapper(self, context, *args, **kwargs):
         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)