Skip to content

Fix BaseAsyncOperator in common-compat provider for Airflow 2.x #60663

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
potiuk merged 8 commits into from
Jan 17, 2026
Merged

Fix BaseAsyncOperator in common-compat provider for Airflow 2.x #60663

Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
b292b73
refactor: Removed definition of xcom_push setter and getter in BaseAs…
dabla Jan 16, 2026
2720353
Merge branch 'main' into fix/base-async-operator-common-compat
dabla Jan 16, 2026
3aa3e30
refactor: Try fixing inheritance issue with missing xcom_push method
dabla Jan 16, 2026
eefb285
Merge branch 'main' into fix/base-async-operator-common-compat
dabla Jan 16, 2026
e09f33a
Merge branch 'main' into fix/base-async-operator-common-compat
dabla Jan 17, 2026
299a410
refactor: Fixed import of legacy BaseOperator
dabla Jan 17, 2026
2162bdf
Merge branch 'main' into fix/base-async-operator-common-compat
dabla Jan 17, 2026
74a1fd2
Merge branch 'main' into fix/base-async-operator-common-compat
dabla Jan 17, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 1 addition & 12 deletions providers/common/compat/src/airflow/providers/common/compat/standard/operators.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@

from airflow.providers.common.compat._compat_utils import create_module_getattr
from airflow.providers.common.compat.version_compat import (
AIRFLOW_V_3_0_PLUS,
AIRFLOW_V_3_1_PLUS,
AIRFLOW_V_3_2_PLUS,
)
Expand All @@ -45,7 +44,7 @@
from airflow.sdk.bases.decorator import is_async_callable
from airflow.sdk.bases.operator import BaseAsyncOperator
else:
if AIRFLOW_V_3_0_PLUS:
if AIRFLOW_V_3_1_PLUS:
from airflow.sdk import BaseOperator
else:
from airflow.models import BaseOperator
Expand All @@ -66,16 +65,6 @@ class BaseAsyncOperator(BaseOperator):
def is_async(self) -> bool:
return True

if not AIRFLOW_V_3_1_PLUS:

@property
def xcom_push(self) -> bool:
return self.do_xcom_push

@xcom_push.setter
def xcom_push(self, value: bool):
self.do_xcom_push = value

async def aexecute(self, context):
raise NotImplementedError()

Expand Down