From cec372e3021805c3b8af652c22003825203867cc Mon Sep 17 00:00:00 2001
From: Justin Bandoro <79104794+jbandoro@users.noreply.github.com>
Date: Wed, 21 Feb 2024 14:18:05 -0800
Subject: [PATCH] Fix failing test_created_pod for
 `apache-airflow-providers-cncf-kubernetes` after v8.0.0 update (#854)

Instead of comparing the full k8s pod as a dictionary, which isn't
necessary and was resulting in the failing unit test described in #853,
the test was updated to compare the metadata and container fields that
are relevant to cosmos.

Closes #853
---
 tests/operators/test_kubernetes.py | 134 ++++++-----------------------
 1 file changed, 27 insertions(+), 107 deletions(-)

diff --git a/tests/operators/test_kubernetes.py b/tests/operators/test_kubernetes.py
index e267b9b05..19a6c7aeb 100644
--- a/tests/operators/test_kubernetes.py
+++ b/tests/operators/test_kubernetes.py
@@ -255,117 +255,37 @@ def cleanup(pod: str, remote_pod: str):
 
 
 def test_created_pod():
-    ls_kwargs = {"env_vars": {"FOO": "BAR"}}
+    ls_kwargs = {"env_vars": {"FOO": "BAR"}, "namespace": "foo"}
     ls_kwargs.update(base_kwargs)
     ls_operator = DbtLSKubernetesOperator(**ls_kwargs)
     ls_operator.hook = MagicMock()
     ls_operator.hook.is_in_cluster = False
-    ls_operator.hook._get_namespace.return_value.to_dict.return_value = "foo"
     ls_operator.build_kube_args(context={}, cmd_flags=MagicMock())
     pod_obj = ls_operator.build_pod_request_obj()
-    expected_result = {
-        "api_version": "v1",
-        "kind": "Pod",
-        "metadata": {
-            "annotations": {},
-            "cluster_name": None,
-            "creation_timestamp": None,
-            "deletion_grace_period_seconds": None,
-            "deletion_timestamp": None,
-            "finalizers": None,
-            "generate_name": None,
-            "generation": None,
-            "labels": {
-                "airflow_kpo_in_cluster": "False",
-                "airflow_version": pod_obj.metadata.labels["airflow_version"],
-            },
-            "managed_fields": None,
-            "name": pod_obj.metadata.name,
-            "owner_references": None,
-            "resource_version": None,
-            "self_link": None,
-            "uid": None,
-        },
-        "spec": {
-            "active_deadline_seconds": None,
-            "affinity": {},
-            "automount_service_account_token": None,
-            "containers": [
-                {
-                    "args": [
-                        "dbt",
-                        "ls",
-                        "--vars",
-                        "end_time: '{{ "
-                        "data_interval_end.strftime(''%Y%m%d%H%M%S'') "
-                        "}}'\n"
-                        "start_time: '{{ "
-                        "data_interval_start.strftime(''%Y%m%d%H%M%S'') "
-                        "}}'\n",
-                        "--no-version-check",
-                        "--project-dir",
-                        "my/dir",
-                    ],
-                    "command": [],
-                    "env": [{"name": "FOO", "value": "BAR", "value_from": None}],
-                    "env_from": [],
-                    "image": "my_image",
-                    "image_pull_policy": None,
-                    "lifecycle": None,
-                    "liveness_probe": None,
-                    "name": "base",
-                    "ports": [],
-                    "readiness_probe": None,
-                    "resources": None,
-                    "security_context": None,
-                    "startup_probe": None,
-                    "stdin": None,
-                    "stdin_once": None,
-                    "termination_message_path": None,
-                    # "termination_message_policy": None,
-                    "tty": None,
-                    "volume_devices": None,
-                    "volume_mounts": [],
-                    "working_dir": None,
-                }
-            ],
-            "dns_config": None,
-            "dns_policy": None,
-            "enable_service_links": None,
-            "ephemeral_containers": None,
-            "host_aliases": None,
-            "host_ipc": None,
-            "host_network": False,
-            "host_pid": None,
-            "hostname": None,
-            "image_pull_secrets": [],
-            "init_containers": [],
-            "node_name": None,
-            "node_selector": {},
-            "os": None,
-            "overhead": None,
-            "preemption_policy": None,
-            "priority": None,
-            "priority_class_name": None,
-            "readiness_gates": None,
-            "restart_policy": "Never",
-            "runtime_class_name": None,
-            "scheduler_name": None,
-            "security_context": {},
-            "service_account": None,
-            "service_account_name": None,
-            "set_hostname_as_fqdn": None,
-            "share_process_namespace": None,
-            "subdomain": None,
-            "termination_grace_period_seconds": None,
-            "tolerations": [],
-            "topology_spread_constraints": None,
-            "volumes": [],
-        },
-        "status": None,
-    }
 
-    computed_result = pod_obj.to_dict()
-    computed_result["spec"]["containers"][0].pop("termination_message_policy")
-    computed_result["metadata"].pop("namespace")
-    assert computed_result == expected_result
+    metadata = pod_obj.metadata
+    assert metadata.labels["airflow_kpo_in_cluster"] == "False"
+    assert metadata.namespace == "foo"
+
+    container = pod_obj.spec.containers[0]
+    assert container.env[0].name == "FOO"
+    assert container.env[0].value == "BAR"
+    assert container.env[0].value_from is None
+    assert container.image == "my_image"
+
+    expected_container_args = [
+        "dbt",
+        "ls",
+        "--vars",
+        "end_time: '{{ "
+        "data_interval_end.strftime(''%Y%m%d%H%M%S'') "
+        "}}'\n"
+        "start_time: '{{ "
+        "data_interval_start.strftime(''%Y%m%d%H%M%S'') "
+        "}}'\n",
+        "--no-version-check",
+        "--project-dir",
+        "my/dir",
+    ]
+    assert container.args == expected_container_args
+    assert container.command == []