This is an automated email from the ASF dual-hosted git repository.
potiuk 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 5b2d2fc3b46 Add BaseXcom to airflow.sdk (#63116)
5b2d2fc3b46 is described below
commit 5b2d2fc3b4615987571e319f71ca30d51adfb98e
Author: Jarek Potiuk <[email protected]>
AuthorDate: Sun Mar 8 16:50:12 2026 +0100
Add BaseXcom to airflow.sdk (#63116)
---
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 669c87e019a..fb7410c3202 100644
--- a/task-sdk/src/airflow/sdk/__init__.py
+++ b/task-sdk/src/airflow/sdk/__init__.py
@@ -34,6 +34,7 @@ __all__ = [
"BaseOperator",
"BaseOperatorLink",
"BaseSensorOperator",
+ "BaseXCom",
"BranchMixIn",
"Connection",
"Context",
@@ -108,6 +109,7 @@ if TYPE_CHECKING:
from airflow.sdk.bases.operatorlink import BaseOperatorLink
from airflow.sdk.bases.sensor import BaseSensorOperator, PokeReturnValue
from airflow.sdk.bases.skipmixin import SkipMixin
+ from airflow.sdk.bases.xcom import BaseXCom
from airflow.sdk.configuration import AirflowSDKConfigParser
from airflow.sdk.definitions.asset import Asset, AssetAlias, AssetAll,
AssetAny, AssetWatcher
from airflow.sdk.definitions.asset.decorators import asset
@@ -173,6 +175,7 @@ __lazy_imports: dict[str, str] = {
"BaseOperator": ".bases.operator",
"BaseOperatorLink": ".bases.operatorlink",
"BaseSensorOperator": ".bases.sensor",
+ "BaseXCom": ".bases.xcom",
"BranchMixIn": ".bases.branch",
"Connection": ".definitions.connection",
"Context": ".definitions.context",
diff --git a/task-sdk/src/airflow/sdk/__init__.pyi
b/task-sdk/src/airflow/sdk/__init__.pyi
index ed9943700b5..222b776c1aa 100644
--- a/task-sdk/src/airflow/sdk/__init__.pyi
+++ b/task-sdk/src/airflow/sdk/__init__.pyi
@@ -40,6 +40,7 @@ from airflow.sdk.bases.sensor import (
PokeReturnValue as PokeReturnValue,
)
from airflow.sdk.bases.skipmixin import SkipMixin as SkipMixin
+from airflow.sdk.bases.xcom import BaseXCom as BaseXCom
from airflow.sdk.configuration import AirflowSDKConfigParser
from airflow.sdk.definitions.asset import (
Asset as Asset,
@@ -112,6 +113,7 @@ __all__ = [
"BaseOperator",
"BaseOperatorLink",
"BaseSensorOperator",
+ "BaseXCom",
"BranchMixIn",
"Connection",
"Context",