You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by di...@apache.org on 2020/11/19 05:46:57 UTC

[airflow] branch v1-10-test updated: fixup! Change back example_kubernetes_executor_config to KubernetesExecutor

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

dimberman pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/v1-10-test by this push:
     new bcad244   fixup! Change back example_kubernetes_executor_config to KubernetesExecutor
bcad244 is described below

commit bcad24480aefaa55955d5f07f1b73bbfa58a643d
Author: Daniel Imberman <da...@gmail.com>
AuthorDate: Wed Nov 18 21:37:23 2020 -0800

     fixup! Change back example_kubernetes_executor_config to KubernetesExecutor
---
 tests/serialization/test_dag_serialization.py | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/tests/serialization/test_dag_serialization.py b/tests/serialization/test_dag_serialization.py
index 30493fd..d999cb0 100644
--- a/tests/serialization/test_dag_serialization.py
+++ b/tests/serialization/test_dag_serialization.py
@@ -259,14 +259,6 @@ class TestStringifiedDAGs(unittest.TestCase):
 
         assert sorted_serialized_dag(ground_truth_dag) == sorted_serialized_dag(json_dag)
 
-    def test_deser_k8s_pod_override(self):
-        dag = collect_dags('airflow/example_dags')['example_kubernetes_executor_config']
-        serialized = SerializedDAG.to_json(dag)
-        deser_dag = SerializedDAG.from_json(serialized)
-        p1 = dag.tasks[1].executor_config
-        p2 = deser_dag.tasks[1].executor_config
-        self.assertDictEqual(p1['pod_override'].to_dict(), p2['pod_override'].to_dict())
-
     def test_deserialization_across_process(self):
         """A serialized DAG can be deserialized in another process."""