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 687b86741ec Add other executor tests to K8s tests (#47472)
687b86741ec is described below
commit 687b86741ec5ec30bdc05f7087e884d98418ae7e
Author: Jens Scheffler <[email protected]>
AuthorDate: Sat Mar 8 17:44:25 2025 +0100
Add other executor tests to K8s tests (#47472)
* Add other executor tests to K8s tests
* Use all k8s tests
* Add missing dependency to airflow models
* Mark LocalExecutor as XFail due to issue #47518
---
dev/breeze/src/airflow_breeze/commands/kubernetes_commands.py | 2 +-
kubernetes_tests/test_other_executors.py | 6 +++++-
scripts/ci/kubernetes/k8s_requirements.txt | 1 +
3 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/dev/breeze/src/airflow_breeze/commands/kubernetes_commands.py
b/dev/breeze/src/airflow_breeze/commands/kubernetes_commands.py
index 439b1e8f67e..073d6752300 100644
--- a/dev/breeze/src/airflow_breeze/commands/kubernetes_commands.py
+++ b/dev/breeze/src/airflow_breeze/commands/kubernetes_commands.py
@@ -1468,7 +1468,7 @@ def _run_tests(
f"[info]You can deploy airflow with {executor} by
running:[/]\nbreeze k8s configure-cluster\nbreeze k8s deploy-airflow
--multi-namespace-mode --executor {executor}"
)
return 1, f"Tests {kubectl_cluster_name}"
- the_tests: list[str] =
["kubernetes_tests/test_kubernetes_executor.py::TestKubernetesExecutor"]
+ the_tests: list[str] = ["kubernetes_tests/"]
command_to_run = " ".join([quote(arg) for arg in ["python3", "-m",
"pytest", *the_tests, *test_args]])
get_console(output).print(f"[info] Command to run:[/] {command_to_run}")
result = run_command(
diff --git a/kubernetes_tests/test_other_executors.py
b/kubernetes_tests/test_other_executors.py
index 63fe8020548..f8203b069b4 100644
--- a/kubernetes_tests/test_other_executors.py
+++ b/kubernetes_tests/test_other_executors.py
@@ -31,6 +31,10 @@ from kubernetes_tests.test_base import (
# Also, the skipping is necessary as there's no gain in running these tests in
KubernetesExecutor
@pytest.mark.skipif(EXECUTOR == "KubernetesExecutor", reason="Does not run on
KubernetesExecutor")
class TestCeleryAndLocalExecutor(BaseK8STest):
+ @pytest.mark.xfail(
+ EXECUTOR == "LocalExecutor",
+ reason="https://github.com/apache/airflow/issues/47518 needs to be
fixed",
+ )
def test_integration_run_dag(self):
dag_id = "example_bash_operator"
dag_run_id, logical_date = self.start_job_in_kubernetes(dag_id,
self.host)
@@ -56,7 +60,7 @@ class TestCeleryAndLocalExecutor(BaseK8STest):
@pytest.mark.xfail(
EXECUTOR == "LocalExecutor",
- reason="https://github.com/apache/airflow/issues/44481 needs to be
implemented",
+ reason="https://github.com/apache/airflow/issues/47518 needs to be
fixed",
)
def test_integration_run_dag_with_scheduler_failure(self):
dag_id = "example_xcom"
diff --git a/scripts/ci/kubernetes/k8s_requirements.txt
b/scripts/ci/kubernetes/k8s_requirements.txt
index 0fbbf3827c3..505163bf204 100644
--- a/scripts/ci/kubernetes/k8s_requirements.txt
+++ b/scripts/ci/kubernetes/k8s_requirements.txt
@@ -2,3 +2,4 @@
-e ./task-sdk
-e ./devel-common
-e ./providers/cncf/kubernetes
+-e . # Need this until all airflow.models are migrated to Task SDK
