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 5d44373487c Reduce unneeded unit tests (#64551)
5d44373487c is described below
commit 5d44373487c144d2dd956fe95669e91dba5c1814
Author: Brent Bovenzi <[email protected]>
AuthorDate: Wed Apr 1 06:23:25 2026 -0400
Reduce unneeded unit tests (#64551)
---
.../execution_api/versions/head/test_health.py | 10 ++++++++++
.../basic_tests/test_basic_dag_operations.py | 17 +----------------
.../remote_log_tests/test_remote_logging.py | 5 -----
3 files changed, 11 insertions(+), 21 deletions(-)
diff --git
a/airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_health.py
b/airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_health.py
index dc13f9880a8..0e3664dd536 100644
---
a/airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_health.py
+++
b/airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_health.py
@@ -26,3 +26,13 @@ def test_health(client):
assert response.status_code == 200
assert response.json() == {"status": "healthy"}
+
+
+def test_ping(client):
+ """All registered services should report healthy, returning 200 with no
failures."""
+ response = client.get("/execution/health/ping")
+
+ assert response.status_code == 200
+ body = response.json()
+ assert "ok" in body
+ assert body["failing"] == {}, f"Unexpected failing services:
{body['failing']}"
diff --git
a/airflow-e2e-tests/tests/airflow_e2e_tests/basic_tests/test_basic_dag_operations.py
b/airflow-e2e-tests/tests/airflow_e2e_tests/basic_tests/test_basic_dag_operations.py
index 63ed6f8036b..6fc7603fcea 100644
---
a/airflow-e2e-tests/tests/airflow_e2e_tests/basic_tests/test_basic_dag_operations.py
+++
b/airflow-e2e-tests/tests/airflow_e2e_tests/basic_tests/test_basic_dag_operations.py
@@ -18,7 +18,7 @@ from __future__ import annotations
from datetime import datetime, timezone
-from airflow_e2e_tests.e2e_test_utils.clients import AirflowClient,
TaskSDKClient
+from airflow_e2e_tests.e2e_test_utils.clients import AirflowClient
class TestBasicDagFunctionality:
@@ -26,11 +26,6 @@ class TestBasicDagFunctionality:
airflow_client = AirflowClient()
- def test_dag_unpause(self):
- self.airflow_client.un_pause_dag(
- "example_xcom_test",
- )
-
def test_xcom_value(self):
resp = self.airflow_client.trigger_dag(
"example_xcom_test", json={"logical_date":
datetime.now(timezone.utc).isoformat()}
@@ -46,13 +41,3 @@ class TestBasicDagFunctionality:
run_id=resp["dag_run_id"],
)
assert xcom_value_resp["value"] == "manually_pushed_value",
xcom_value_resp
-
-
-class TestTaskSDKBasicFunctionality:
- """Test basic functionality of Task SDK using the Task SDK REST API."""
-
- task_sdk_client = TaskSDKClient()
-
- def test_task_sdk_health_check(self):
- response = self.task_sdk_client.health_check()
- assert response.status_code == 200
diff --git
a/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
b/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
index 9260f0abe03..f424e39d0a5 100644
---
a/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
+++
b/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
@@ -31,11 +31,6 @@ class TestRemoteLogging:
retry_interval_in_seconds = 5
max_retries = 12
- def test_dag_unpause(self):
- self.airflow_client.un_pause_dag(
- TestRemoteLogging.dag_id,
- )
-
def test_remote_logging_s3(self):
"""Test that a DAG using remote logging to S3 completes
successfully."""
