From ae46077b9a093700472eabd5e2781e7ea60c69a6 Mon Sep 17 00:00:00 2001 From: Jens Scheffler Date: Sun, 7 Jun 2026 12:43:28 +0200 Subject: [PATCH] Mark Java SDK E2E test XFail until #68160 resolved --- .../airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/airflow-e2e-tests/tests/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py b/airflow-e2e-tests/tests/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py index 0e99a399f2d44..523658d95d30f 100644 --- a/airflow-e2e-tests/tests/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py +++ b/airflow-e2e-tests/tests/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py @@ -64,6 +64,9 @@ class TestJavaSDKAnnotationExample: airflow_client = AirflowClient() @pytest.mark.parametrize("dag_id", ["java_annotation_example"]) + @pytest.mark.xfail( + reason="Test is instable and needs fixing: https://github.com/apache/airflow/issues/68160" + ) def test_java_tasks_execute_successfully(self, dag_id: str): """Both Java stubs in the annotation example must succeed.""" resp = self.airflow_client.trigger_dag( @@ -99,6 +102,9 @@ def test_java_tasks_execute_successfully(self, dag_id: str): f" all tasks : { {k: v.get('state') for k, v in ti_map.items()} }" ) + @pytest.mark.xfail( + reason="Test is instable and needs fixing: https://github.com/apache/airflow/issues/68160" + ) def test_transform_xcom_is_numeric_timestamp(self): """The value returned by the Java 'transform' task must be a positive integer.""" resp = self.airflow_client.trigger_dag(