[airflow] branch main updated: Fix broken KubeExecutor tests (#19680)

[as...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ash 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 78503e0  Fix broken KubeExecutor tests (#19680)
78503e0 is described below

commit 78503e0cd562be422a142d49461cbc27b2982ad2
Author: Ash Berlin-Taylor <as...@firemirror.com>
AuthorDate: Thu Nov 18 16:46:26 2021 +0000

    Fix broken KubeExecutor tests (#19680)
    
    We had deleted the example_kubernetes_executor_config dag and put it all
    in the sinle example_kubernetes_executor, but the tests had been broken
    for a while that we didn't notice.
---
 kubernetes_tests/test_kubernetes_executor.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kubernetes_tests/test_kubernetes_executor.py b/kubernetes_tests/test_kubernetes_executor.py
index 1ca3848..61030d1 100644
--- a/kubernetes_tests/test_kubernetes_executor.py
+++ b/kubernetes_tests/test_kubernetes_executor.py
@@ -25,7 +25,7 @@ from kubernetes_tests.test_base import EXECUTOR, TestBase
 @pytest.mark.skipif(EXECUTOR != 'KubernetesExecutor', reason="Only runs on KubernetesExecutor")
 class TestKubernetesExecutor(TestBase):
     def test_integration_run_dag(self):
-        dag_id = 'example_kubernetes_executor_config'
+        dag_id = 'example_kubernetes_executor'
         dag_run_id, execution_date = self.start_job_in_kubernetes(dag_id, self.host)
         print(f"Found the job with execution_date {execution_date}")
 
@@ -48,7 +48,7 @@ class TestKubernetesExecutor(TestBase):
         )
 
     def test_integration_run_dag_with_scheduler_failure(self):
-        dag_id = 'example_kubernetes_executor_config'
+        dag_id = 'example_kubernetes_executor'
 
         dag_run_id, execution_date = self.start_job_in_kubernetes(dag_id, self.host)