This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new f7c88912831 Add BaseXcom to airflow.sdk (#63116) (#63299)
f7c88912831 is described below
commit f7c88912831d665595f6ea13e1c1d2427d3ffd24
Author: Rahul Vats <[email protected]>
AuthorDate: Wed Mar 11 04:08:00 2026 +0530
Add BaseXcom to airflow.sdk (#63116) (#63299)
(cherry picked from commit 5b2d2fc3b4615987571e319f71ca30d51adfb98e)
Co-authored-by: Jarek Potiuk <[email protected]>
---
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",
