This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 8bee736db80 Remove some remnants of airflow.utils.xcom usage in core
(#53169)
8bee736db80 is described below
commit 8bee736db80eebc9d66cd31af1b1019ea8acbd22
Author: Amogh Desai <[email protected]>
AuthorDate: Fri Jul 11 15:12:58 2025 +0530
Remove some remnants of airflow.utils.xcom usage in core (#53169)
---
airflow-core/src/airflow/models/taskinstance.py | 3 +--
airflow-core/src/airflow/models/xcom_arg.py | 2 +-
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/airflow-core/src/airflow/models/taskinstance.py
b/airflow-core/src/airflow/models/taskinstance.py
index 77fd3ae0d3d..11bbc7080ab 100644
--- a/airflow-core/src/airflow/models/taskinstance.py
+++ b/airflow-core/src/airflow/models/taskinstance.py
@@ -84,7 +84,7 @@ from airflow.models.log import Log
from airflow.models.taskinstancekey import TaskInstanceKey
from airflow.models.taskmap import TaskMap
from airflow.models.taskreschedule import TaskReschedule
-from airflow.models.xcom import LazyXComSelectSequence, XComModel
+from airflow.models.xcom import XCOM_RETURN_KEY, LazyXComSelectSequence,
XComModel
from airflow.settings import task_instance_mutation_hook
from airflow.stats import Stats
from airflow.ti_deps.dep_context import DepContext
@@ -100,7 +100,6 @@ from airflow.utils.session import NEW_SESSION,
create_session, provide_session
from airflow.utils.span_status import SpanStatus
from airflow.utils.sqlalchemy import ExecutorConfigType, ExtendedJSON,
UtcDateTime
from airflow.utils.state import DagRunState, State, TaskInstanceState
-from airflow.utils.xcom import XCOM_RETURN_KEY
TR = TaskReschedule
diff --git a/airflow-core/src/airflow/models/xcom_arg.py
b/airflow-core/src/airflow/models/xcom_arg.py
index cfda9295cec..1109f03bb1f 100644
--- a/airflow-core/src/airflow/models/xcom_arg.py
+++ b/airflow-core/src/airflow/models/xcom_arg.py
@@ -25,6 +25,7 @@ import attrs
from sqlalchemy import func, or_, select
from sqlalchemy.orm import Session
+from airflow.models.xcom import XCOM_RETURN_KEY
from airflow.sdk.definitions._internal.types import ArgNotSet
from airflow.sdk.definitions.mappedoperator import MappedOperator
from airflow.sdk.definitions.xcom_arg import (
@@ -33,7 +34,6 @@ from airflow.sdk.definitions.xcom_arg import (
from airflow.utils.db import exists_query
from airflow.utils.state import State
from airflow.utils.types import NOTSET
-from airflow.utils.xcom import XCOM_RETURN_KEY
__all__ = ["XComArg", "get_task_map_length"]
