diff --git a/airflow/lineage/__init__.py b/airflow/lineage/__init__.py index 1ca6ad0604f65..6500d8008ea46 100644 --- 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)