This is an automated email from the ASF dual-hosted git repository. rahulvats pushed a commit to branch backport-63116 in repository https://gitbox.apache.org/repos/asf/airflow.git
commit d0d97728bc5413d6fbd6f4eb695ba4e588c5892d Author: Jarek Potiuk <[email protected]> AuthorDate: Sun Mar 8 16:50:12 2026 +0100 Add BaseXcom to airflow.sdk (#63116) (cherry picked from commit 5b2d2fc3b4615987571e319f71ca30d51adfb98e) --- task-sdk/src/airflow/sdk/__init__.py | 3 +++ task-sdk/src/airflow/sdk/__init__.pyi | 2 ++ 2 files changed, 5 insertions(+) diff --git a/task-sdk/src/airflow/sdk/__init__.py b/task-sdk/src/airflow/sdk/__init__.py index 2eaa5ccd2a2..6386ec4f07d 100644 --- a/task-sdk/src/airflow/sdk/__init__.py +++ b/task-sdk/src/airflow/sdk/__init__.py @@ -30,6 +30,7 @@ __all__ = [ "BaseOperator", "BaseOperatorLink", "BaseSensorOperator", + "BaseXCom", "Connection", "Context", "DAG", @@ -70,6 +71,7 @@ if TYPE_CHECKING: from airflow.sdk.bases.operator import BaseOperator, chain, chain_linear, cross_downstream from airflow.sdk.bases.operatorlink import BaseOperatorLink from airflow.sdk.bases.sensor import BaseSensorOperator, PokeReturnValue + from airflow.sdk.bases.xcom import BaseXCom from airflow.sdk.definitions.asset import Asset, AssetAlias, AssetAll, AssetAny, AssetWatcher from airflow.sdk.definitions.asset.decorators import asset from airflow.sdk.definitions.asset.metadata import Metadata @@ -97,6 +99,7 @@ __lazy_imports: dict[str, str] = { "BaseOperator": ".bases.operator", "BaseOperatorLink": ".bases.operatorlink", "BaseSensorOperator": ".bases.sensor", + "BaseXCom": ".bases.xcom", "Connection": ".definitions.connection", "Context": ".definitions.context", "DAG": ".definitions.dag", diff --git a/task-sdk/src/airflow/sdk/__init__.pyi b/task-sdk/src/airflow/sdk/__init__.pyi index bf7f63b209a..e36664594b4 100644 --- a/task-sdk/src/airflow/sdk/__init__.pyi +++ b/task-sdk/src/airflow/sdk/__init__.pyi @@ -34,6 +34,7 @@ from airflow.sdk.bases.sensor import ( BaseSensorOperator as BaseSensorOperator, PokeReturnValue as PokeReturnValue, ) +from airflow.sdk.bases.xcom import BaseXCom as BaseXCom from airflow.sdk.definitions.asset import ( Asset as Asset, AssetAlias as AssetAlias, @@ -73,6 +74,7 @@ __all__ = [ "BaseOperator", "BaseOperatorLink", "BaseSensorOperator", + "BaseXCom", "Connection", "Context", "DAG",
