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."""