Skip to content
6 changes: 1 addition & 5 deletions airflow/models/baseoperator.py
Original file line number Diff line number Diff line change
Expand Up @@ -1592,7 +1592,6 @@ def xcom_push(
context: Any,
key: str,
value: Any,
execution_date: datetime | None = None,
) -> None:
"""
Make an XCom available for tasks to pull.
Expand All @@ -1601,11 +1600,8 @@ def xcom_push(
:param key: A key for the XCom
:param value: A value for the XCom. The value is pickled and stored
in the database.
:param execution_date: if provided, the XCom will not be visible until
this date. This can be used, for example, to send a message to a
task on a future date without it being immediately visible.
"""
context["ti"].xcom_push(key=key, value=value, execution_date=execution_date)
context["ti"].xcom_push(key=key, value=value)

@staticmethod
@provide_session
Expand Down
16 changes: 1 addition & 15 deletions airflow/models/taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,6 @@
AirflowSkipException,
AirflowTaskTerminated,
AirflowTaskTimeout,
RemovedInAirflow3Warning,
TaskDeferralError,
TaskDeferred,
UnmappableXComLengthPushed,
Expand Down Expand Up @@ -3473,7 +3472,6 @@ def xcom_push(
self,
key: str,
value: Any,
execution_date: datetime | None = None,
session: Session = NEW_SESSION,
) -> None:
"""
Expand All @@ -3483,19 +3481,7 @@ def xcom_push(
:param value: Value to store. What types are possible depends on whether
``enable_xcom_pickling`` is true or not. If so, this can be any
picklable object; only be JSON-serializable may be used otherwise.
:param execution_date: Deprecated parameter that has no effect.
"""
if execution_date is not None:
self_execution_date = self.get_dagrun(session).execution_date
if execution_date < self_execution_date:
raise ValueError(
f"execution_date can not be in the past (current execution_date is "
f"{self_execution_date}; received {execution_date})"
)
elif execution_date is not None:
message = "Passing 'execution_date' to 'TaskInstance.xcom_push()' is deprecated."
warnings.warn(message, RemovedInAirflow3Warning, stacklevel=3)

"""
XCom.set(
key=key,
value=value,
Expand Down
Loading