This is an automated email from the ASF dual-hosted git repository. ashb pushed a commit to branch store-historic-ti-ownership-data in repository https://gitbox.apache.org/repos/asf/airflow.git
commit de76043cf9c873ee29e8fdf395ee0acd341f9811 Author: Ash Berlin-Taylor <[email protected]> AuthorDate: Mon Oct 5 17:43:24 2026 +0100 fixup! Keep retired task attempts and their data under the attempt UUID --- providers/standard/tests/unit/standard/operators/test_weekday.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/providers/standard/tests/unit/standard/operators/test_weekday.py b/providers/standard/tests/unit/standard/operators/test_weekday.py index 957c94e7295..19326664d77 100644 --- a/providers/standard/tests/unit/standard/operators/test_weekday.py +++ b/providers/standard/tests/unit/standard/operators/test_weekday.py @@ -34,13 +34,9 @@ from airflow.timetables.base import DataInterval from airflow.utils.session import create_session from airflow.utils.state import State +from tests_common.test_utils.db import clear_db_xcom from tests_common.test_utils.version_compat import AIRFLOW_V_3_0_1, AIRFLOW_V_3_0_PLUS -if AIRFLOW_V_3_0_PLUS: - from airflow.models.xcom import XComModel as XCom -else: - from airflow.models.xcom import XCom # type: ignore[no-redef] - pytestmark = pytest.mark.db_test DEFAULT_DATE = timezone.datetime(2020, 2, 5) # Wednesday @@ -72,7 +68,7 @@ class TestBranchDayOfWeekOperator: with create_session() as session: session.execute(delete(DagRun)) session.execute(delete(TI)) - session.execute(delete(XCom)) + clear_db_xcom() def _assert_task_ids_match_states(self, dr, task_ids_to_states): """Helper that asserts task instances with a given id are in a given state"""
