From c1116e42d70d4bf43c463bb7658e9610752dbd50 Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Wed, 12 Nov 2025 19:10:04 +0000 Subject: [PATCH 1/8] set flaky test Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- tests/suite/test_virtual_server_foreign_upstream.py | 1 + 1 file changed, 1 insertion(+) diff --git a/tests/suite/test_virtual_server_foreign_upstream.py b/tests/suite/test_virtual_server_foreign_upstream.py index 11ac55eca9..b0b4a22d1e 100644 --- a/tests/suite/test_virtual_server_foreign_upstream.py +++ b/tests/suite/test_virtual_server_foreign_upstream.py @@ -106,6 +106,7 @@ def fin(): indirect=True, ) class TestVirtualServerForeignUpstream: + @pytest.mark.flaky(max_runs=3) def test_responses_after_setup(self, kube_apis, crd_ingress_controller, virtual_server_foreign_upstream_app_setup): print(f"\nStep 1: initial check") wait_before_test() From 762b5a6714ee48b7607dcc47f9f7b4c47b71058e Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Wed, 12 Nov 2025 20:33:44 +0000 Subject: [PATCH 2/8] add namespace in log Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- internal/k8s/controller.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/k8s/controller.go b/internal/k8s/controller.go index 58ad41d198..606477529e 100644 --- a/internal/k8s/controller.go +++ b/internal/k8s/controller.go @@ -2251,7 +2251,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali } if err != nil { - nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v: %v", ing.Spec.DefaultBackend.Service.Name, err) + nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v/%v: %v", ing.Namespace, ing.Spec.DefaultBackend.Service.Name, err) } if svc != nil && !external && hasUseClusterIP { @@ -2963,7 +2963,7 @@ func (lbc *LoadBalancerController) getEndpointsForUpstream(namespace string, ups endps, isExternal, err = lbc.getEndpointsForIngressBackend(backend, svc) if err != nil { - return nil, false, fmt.Errorf("error retrieving endpoints for the service %v: %w", upstreamService, err) + return nil, false, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, upstreamService, err) } return endps, isExternal, err @@ -2993,7 +2993,7 @@ func (lbc *LoadBalancerController) getEndpointsForSubselector(namespace string, endps, err = lbc.getEndpointsForServiceWithSubselector(targetPort, subselector, svc) if err != nil { - return nil, fmt.Errorf("error retrieving endpoints for the service %v: %w", serviceName, err) + return nil, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, serviceName, err) } return endps, err @@ -3217,7 +3217,7 @@ func (lbc *LoadBalancerController) getEndpointsForPortFromEndpointSlices(endpoin endpoints := makePodEndpoints(targetPort, filterReadyEndpointsFrom(selectEndpointSlicesForPort(targetPort, endpointSlices))) if len(endpoints) == 0 { - return nil, fmt.Errorf("no endpointslices for target port %v in service %s", targetPort, svc.Name) + return nil, fmt.Errorf("no endpointslices for target port %v in service %s/%s", targetPort, svc.Namespace, svc.Name) } return endpoints, nil } From a23755cda9ee41d8f3e451ae4eaccba5c32f94a0 Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Wed, 12 Nov 2025 21:47:03 +0000 Subject: [PATCH 3/8] create namespace before deploying VS Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- tests/suite/test_virtual_server_foreign_upstream.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/tests/suite/test_virtual_server_foreign_upstream.py b/tests/suite/test_virtual_server_foreign_upstream.py index b0b4a22d1e..9d69b10be1 100644 --- a/tests/suite/test_virtual_server_foreign_upstream.py +++ b/tests/suite/test_virtual_server_foreign_upstream.py @@ -44,11 +44,8 @@ def virtual_server_foreign_upstream_app_setup( :param test_namespace: :return: VirtualServerSetup """ - print("------------------------- Deploy Virtual Server Example -----------------------------------") + print("------------------------- Create namespaces -----------------------------------") vs_source = f"{TEST_DATA}/{request.param['example']}/standard/virtual-server.yaml" - vs_name = create_virtual_server_from_yaml(kube_apis.custom_objects, vs_source, test_namespace) - vs_host = get_first_host_from_yaml(vs_source) - vs_paths = get_paths_from_vs_yaml(vs_source) upstream_namespaces = get_upstream_namespace_from_vs_yaml(vs_source, test_namespace) print(f"Upstream namespaces detected in the VS yaml: {upstream_namespaces}") ns_1 = ( @@ -61,6 +58,10 @@ def virtual_server_foreign_upstream_app_setup( if upstream_namespaces[1] != test_namespace else test_namespace ) + print("------------------------- Deploy Virtual Server Example -----------------------------------") + vs_name = create_virtual_server_from_yaml(kube_apis.custom_objects, vs_source, test_namespace) + vs_host = get_first_host_from_yaml(vs_source) + vs_paths = get_paths_from_vs_yaml(vs_source) create_items_from_yaml(kube_apis, f"{TEST_DATA}/common/app/{request.param['app_type']}/backend1.yaml", ns_1) create_items_from_yaml(kube_apis, f"{TEST_DATA}/common/app/{request.param['app_type']}/backend2.yaml", ns_2) From e10b1789d64ce1368f9d68bbfa76dd71a0a251e4 Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Thu, 13 Nov 2025 12:38:54 +0000 Subject: [PATCH 4/8] revert adding namespace in log, formatting, remove flaky marker Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- internal/k8s/controller.go | 8 ++++---- tests/suite/test_virtual_server_foreign_upstream.py | 2 -- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/internal/k8s/controller.go b/internal/k8s/controller.go index 606477529e..58ad41d198 100644 --- a/internal/k8s/controller.go +++ b/internal/k8s/controller.go @@ -2251,7 +2251,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali } if err != nil { - nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v/%v: %v", ing.Namespace, ing.Spec.DefaultBackend.Service.Name, err) + nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v: %v", ing.Spec.DefaultBackend.Service.Name, err) } if svc != nil && !external && hasUseClusterIP { @@ -2963,7 +2963,7 @@ func (lbc *LoadBalancerController) getEndpointsForUpstream(namespace string, ups endps, isExternal, err = lbc.getEndpointsForIngressBackend(backend, svc) if err != nil { - return nil, false, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, upstreamService, err) + return nil, false, fmt.Errorf("error retrieving endpoints for the service %v: %w", upstreamService, err) } return endps, isExternal, err @@ -2993,7 +2993,7 @@ func (lbc *LoadBalancerController) getEndpointsForSubselector(namespace string, endps, err = lbc.getEndpointsForServiceWithSubselector(targetPort, subselector, svc) if err != nil { - return nil, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, serviceName, err) + return nil, fmt.Errorf("error retrieving endpoints for the service %v: %w", serviceName, err) } return endps, err @@ -3217,7 +3217,7 @@ func (lbc *LoadBalancerController) getEndpointsForPortFromEndpointSlices(endpoin endpoints := makePodEndpoints(targetPort, filterReadyEndpointsFrom(selectEndpointSlicesForPort(targetPort, endpointSlices))) if len(endpoints) == 0 { - return nil, fmt.Errorf("no endpointslices for target port %v in service %s/%s", targetPort, svc.Namespace, svc.Name) + return nil, fmt.Errorf("no endpointslices for target port %v in service %s", targetPort, svc.Name) } return endpoints, nil } diff --git a/tests/suite/test_virtual_server_foreign_upstream.py b/tests/suite/test_virtual_server_foreign_upstream.py index 9d69b10be1..bd2d0938fa 100644 --- a/tests/suite/test_virtual_server_foreign_upstream.py +++ b/tests/suite/test_virtual_server_foreign_upstream.py @@ -44,7 +44,6 @@ def virtual_server_foreign_upstream_app_setup( :param test_namespace: :return: VirtualServerSetup """ - print("------------------------- Create namespaces -----------------------------------") vs_source = f"{TEST_DATA}/{request.param['example']}/standard/virtual-server.yaml" upstream_namespaces = get_upstream_namespace_from_vs_yaml(vs_source, test_namespace) print(f"Upstream namespaces detected in the VS yaml: {upstream_namespaces}") @@ -107,7 +106,6 @@ def fin(): indirect=True, ) class TestVirtualServerForeignUpstream: - @pytest.mark.flaky(max_runs=3) def test_responses_after_setup(self, kube_apis, crd_ingress_controller, virtual_server_foreign_upstream_app_setup): print(f"\nStep 1: initial check") wait_before_test() From 50fbe713bff17e7c84d096f65d945e03a24200de Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Thu, 13 Nov 2025 13:03:14 +0000 Subject: [PATCH 5/8] add namespaces back Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- internal/k8s/controller.go | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/internal/k8s/controller.go b/internal/k8s/controller.go index 58ad41d198..4a915c1d9e 100644 --- a/internal/k8s/controller.go +++ b/internal/k8s/controller.go @@ -2242,7 +2242,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali var external bool svc, err := lbc.getServiceForIngressBackend(ing.Spec.DefaultBackend, ing.Namespace) if err != nil { - nl.Warnf(lbc.Logger, "Error getting service %v: %v", ing.Spec.DefaultBackend.Service.Name, err) + nl.Warnf(lbc.Logger, "Error getting service %v/%v: %v", ing.Namespace, ing.Spec.DefaultBackend.Service.Name, err) } else { podEndps, external, err = lbc.getEndpointsForIngressBackend(ing.Spec.DefaultBackend, svc) if err == nil && external && lbc.isNginxPlus { @@ -2251,7 +2251,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali } if err != nil { - nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v: %v", ing.Spec.DefaultBackend.Service.Name, err) + nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v/%v: %v", ing.Namespace, ing.Spec.DefaultBackend.Service.Name, err) } if svc != nil && !external && hasUseClusterIP { @@ -2310,7 +2310,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali var external bool svc, err := lbc.getServiceForIngressBackend(&path.Backend, ing.Namespace) if err != nil { - nl.Debugf(lbc.Logger, "Error getting service %v: %v", &path.Backend.Service.Name, err) + nl.Debugf(lbc.Logger, "Error getting service %v/%v: %v", ing.Namespace, path.Backend.Service.Name, err) } else { podEndps, external, err = lbc.getEndpointsForIngressBackend(&path.Backend, svc) if err == nil && external && lbc.isNginxPlus { @@ -2319,7 +2319,7 @@ func (lbc *LoadBalancerController) createIngressEx(ing *networking.Ingress, vali } if err != nil { - nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v: %v", path.Backend.Service.Name, err) + nl.Warnf(lbc.Logger, "Error retrieving endpoints for the service %v/%v: %v", ing.Namespace, path.Backend.Service.Name, err) } if svc != nil && !external && hasUseClusterIP { @@ -2949,7 +2949,7 @@ func (lbc *LoadBalancerController) getTransportServerBackupEndpointsAndKey(trans func (lbc *LoadBalancerController) getEndpointsForUpstream(namespace string, upstreamService string, upstreamPort uint16) (endps []podEndpoint, isExternal bool, err error) { svc, err := lbc.getServiceForUpstream(namespace, upstreamService, upstreamPort) if err != nil { - return nil, false, fmt.Errorf("error getting service %v: %w", upstreamService, err) + return nil, false, fmt.Errorf("error getting service %v/%v: %w", namespace, upstreamService, err) } backend := &networking.IngressBackend{ @@ -2963,7 +2963,7 @@ func (lbc *LoadBalancerController) getEndpointsForUpstream(namespace string, ups endps, isExternal, err = lbc.getEndpointsForIngressBackend(backend, svc) if err != nil { - return nil, false, fmt.Errorf("error retrieving endpoints for the service %v: %w", upstreamService, err) + return nil, false, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, upstreamService, err) } return endps, isExternal, err @@ -2972,7 +2972,7 @@ func (lbc *LoadBalancerController) getEndpointsForUpstream(namespace string, ups func (lbc *LoadBalancerController) getEndpointsForSubselector(namespace string, serviceName string, servicePort uint16, subselector map[string]string) (endps []podEndpoint, err error) { svc, err := lbc.getServiceForUpstream(namespace, serviceName, servicePort) if err != nil { - return nil, fmt.Errorf("error getting service %v: %w", serviceName, err) + return nil, fmt.Errorf("error getting service %v/%v: %w", namespace, serviceName, err) } var targetPort int32 @@ -2993,7 +2993,7 @@ func (lbc *LoadBalancerController) getEndpointsForSubselector(namespace string, endps, err = lbc.getEndpointsForServiceWithSubselector(targetPort, subselector, svc) if err != nil { - return nil, fmt.Errorf("error retrieving endpoints for the service %v: %w", serviceName, err) + return nil, fmt.Errorf("error retrieving endpoints for the service %v/%v: %w", namespace, serviceName, err) } return endps, err @@ -3094,7 +3094,7 @@ func getPodName(pod *api_v1.ObjectReference) string { func (lbc *LoadBalancerController) getHealthChecksForIngressBackend(backend *networking.IngressBackend, namespace string) *api_v1.Probe { svc, err := lbc.getServiceForIngressBackend(backend, namespace) if err != nil { - nl.Debugf(lbc.Logger, "Error getting service %v: %v", backend.Service.Name, err) + nl.Debugf(lbc.Logger, "Error getting service %v/%v: %v", namespace, backend.Service.Name, err) return nil } svcPort := lbc.getServicePortForIngressPort(backend.Service.Port, svc) @@ -3217,7 +3217,7 @@ func (lbc *LoadBalancerController) getEndpointsForPortFromEndpointSlices(endpoin endpoints := makePodEndpoints(targetPort, filterReadyEndpointsFrom(selectEndpointSlicesForPort(targetPort, endpointSlices))) if len(endpoints) == 0 { - return nil, fmt.Errorf("no endpointslices for target port %v in service %s", targetPort, svc.Name) + return nil, fmt.Errorf("no endpointslices for target port %v in service %s/%s", targetPort, svc.Namespace, svc.Name) } return endpoints, nil } From c50ba95fb0288eb130ff2dbb852eba3cd4f35f06 Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Thu, 13 Nov 2025 13:50:14 +0000 Subject: [PATCH 6/8] add namespaces back Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- internal/k8s/controller.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/internal/k8s/controller.go b/internal/k8s/controller.go index 4a915c1d9e..60d42ef224 100644 --- a/internal/k8s/controller.go +++ b/internal/k8s/controller.go @@ -2474,7 +2474,7 @@ func (lbc *LoadBalancerController) createVirtualServerEx(virtualServer *conf_v1. if u.UseClusterIP { s, err := lbc.getServiceForUpstream(serviceNamespace, serviceName, u.Port) if err != nil { - nl.Warnf(lbc.Logger, "Error getting Service for Upstream %v: %v", u.Service, err) + nl.Warnf(lbc.Logger, "Error getting Service for Upstream %v/%v: %v", serviceNamespace, u.Service, err) } else { endps = append(endps, ipv6SafeAddrPort(s.Spec.ClusterIP, int32(u.Port))) } @@ -2622,7 +2622,7 @@ func (lbc *LoadBalancerController) createVirtualServerEx(virtualServer *conf_v1. if u.UseClusterIP { s, err := lbc.getServiceForUpstream(serviceNamespace, serviceName, u.Port) if err != nil { - nl.Warnf(lbc.Logger, "Error getting Service for Upstream %v: %v", u.Service, err) + nl.Warnf(lbc.Logger, "Error getting Service for Upstream %v/%v: %v", serviceNamespace, serviceName, err) } else { endps = append(endps, fmt.Sprintf("%s:%d", s.Spec.ClusterIP, u.Port)) } @@ -2981,14 +2981,14 @@ func (lbc *LoadBalancerController) getEndpointsForSubselector(namespace string, if port.Port == int32(servicePort) { targetPort, err = lbc.getTargetPort(port, svc) if err != nil { - return nil, fmt.Errorf("error determining target port for port %v in service %v: %w", servicePort, svc.Name, err) + return nil, fmt.Errorf("error determining target port for port %v in service %v/%v: %w", servicePort, svc.Namespace, svc.Name, err) } break } } if targetPort == 0 { - return nil, fmt.Errorf("no port %v in service %s", servicePort, svc.Name) + return nil, fmt.Errorf("no port %v in service %s/%s", servicePort, svc.Namespace, svc.Name) } endps, err = lbc.getEndpointsForServiceWithSubselector(targetPort, subselector, svc) @@ -3010,7 +3010,7 @@ func (lbc *LoadBalancerController) getEndpointsForServiceWithSubselector(targetP var svcEndpointSlices []discovery_v1.EndpointSlice svcEndpointSlices, err = nsi.endpointSliceLister.GetServiceEndpointSlices(svc) if err != nil { - nl.Debugf(lbc.Logger, "Error getting endpointslices for service %s from the cache: %v", svc.Name, err) + nl.Debugf(lbc.Logger, "Error getting endpointslices for service %s/%s from the cache: %v", svc.Namespace, svc.Name, err) return nil, err } @@ -3164,13 +3164,13 @@ func (lbc *LoadBalancerController) getEndpointsForIngressBackend(backend *networ result = lbc.getExternalEndpointsForIngressBackend(backend, svc) return result, true, nil } - nl.Debugf(lbc.Logger, "Error getting endpoints for service %s from the cache: %v", svc.Name, err) + nl.Debugf(lbc.Logger, "Error getting endpoints for service %s/%s from the cache: %v", svc.Namespace, svc.Name, err) return nil, false, err } result, err = lbc.getEndpointsForPortFromEndpointSlices(endpointSlices, backend.Service.Port, svc) if err != nil { - nl.Debugf(lbc.Logger, "Error getting endpointslices for service %s port %v: %v", svc.Name, configs.GetBackendPortAsString(backend.Service.Port), err) + nl.Debugf(lbc.Logger, "Error getting endpointslices for service %s/%s port %v: %v", svc.Namespace, svc.Name, configs.GetBackendPortAsString(backend.Service.Port), err) return nil, false, err } return result, false, nil @@ -3191,7 +3191,7 @@ func (lbc *LoadBalancerController) getEndpointsForPortFromEndpointSlices(endpoin } if targetPort == 0 { - return nil, fmt.Errorf("no port %v in service %s", backendPort, svc.Name) + return nil, fmt.Errorf("no port %v in service %s/%s", backendPort, svc.Namespace, svc.Name) } makePodEndpoints := func(port int32, epx []discovery_v1.Endpoint) []podEndpoint { @@ -3281,7 +3281,7 @@ func (lbc *LoadBalancerController) getTargetPort(svcPort api_v1.ServicePort, svc } if len(pods) == 0 { - return 0, fmt.Errorf("no pods of service %s", svc.Name) + return 0, fmt.Errorf("no pods of service %s/%s", svc.Namespace, svc.Name) } pod := pods[0] From 7c55d63f7968433eb32694ec5a81dc8ecb1c47be Mon Sep 17 00:00:00 2001 From: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Date: Thu, 13 Nov 2025 17:14:51 +0000 Subject: [PATCH 7/8] create backend service before VS, log VS conf Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> Signed-off-by: Haywood Shannon <5781935+haywoodsh@users.noreply.github.com> --- .../test_virtual_server_foreign_upstream.py | 22 ++++++++++++++----- 1 file changed, 16 insertions(+), 6 deletions(-) diff --git a/tests/suite/test_virtual_server_foreign_upstream.py b/tests/suite/test_virtual_server_foreign_upstream.py index bd2d0938fa..042a972b41 100644 --- a/tests/suite/test_virtual_server_foreign_upstream.py +++ b/tests/suite/test_virtual_server_foreign_upstream.py @@ -8,14 +8,14 @@ delete_items_from_yaml, delete_namespace, wait_before_test, - wait_until_all_pods_are_ready, + wait_until_all_pods_are_ready, get_first_pod_name, ) from suite.utils.vs_vsr_resources_utils import ( create_v_s_route_from_yaml, create_virtual_server_from_yaml, delete_v_s_route, delete_virtual_server, - patch_virtual_server_from_yaml, + patch_virtual_server_from_yaml, get_vs_nginx_template_conf, ) from suite.utils.yaml_utils import ( get_first_host_from_yaml, @@ -58,14 +58,15 @@ def virtual_server_foreign_upstream_app_setup( else test_namespace ) print("------------------------- Deploy Virtual Server Example -----------------------------------") - vs_name = create_virtual_server_from_yaml(kube_apis.custom_objects, vs_source, test_namespace) - vs_host = get_first_host_from_yaml(vs_source) - vs_paths = get_paths_from_vs_yaml(vs_source) create_items_from_yaml(kube_apis, f"{TEST_DATA}/common/app/{request.param['app_type']}/backend1.yaml", ns_1) create_items_from_yaml(kube_apis, f"{TEST_DATA}/common/app/{request.param['app_type']}/backend2.yaml", ns_2) wait_until_all_pods_are_ready(kube_apis.v1, ns_1) wait_until_all_pods_are_ready(kube_apis.v1, ns_2) + + vs_name = create_virtual_server_from_yaml(kube_apis.custom_objects, vs_source, test_namespace) + vs_host = get_first_host_from_yaml(vs_source) + vs_paths = get_paths_from_vs_yaml(vs_source) def fin(): if request.config.getoption("--skip-fixture-teardown") == "no": @@ -106,8 +107,17 @@ def fin(): indirect=True, ) class TestVirtualServerForeignUpstream: - def test_responses_after_setup(self, kube_apis, crd_ingress_controller, virtual_server_foreign_upstream_app_setup): + def test_responses_after_setup(self, kube_apis,ingress_controller_prerequisites, crd_ingress_controller, virtual_server_foreign_upstream_app_setup): print(f"\nStep 1: initial check") + ic_pod_name = get_first_pod_name(kube_apis.v1, ingress_controller_prerequisites.namespace) + # log VS conf + get_vs_nginx_template_conf( + kube_apis.v1, + virtual_server_foreign_upstream_app_setup.namespace, + virtual_server_foreign_upstream_app_setup.vs_name, + ic_pod_name, + ingress_controller_prerequisites.namespace, + ) wait_before_test() wait_and_assert_status_code( 200, From 784ebc8b87398aeb1f5e7223613789668d4b8fd0 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Thu, 13 Nov 2025 17:15:20 +0000 Subject: [PATCH 8/8] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- .../test_virtual_server_foreign_upstream.py | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/tests/suite/test_virtual_server_foreign_upstream.py b/tests/suite/test_virtual_server_foreign_upstream.py index 042a972b41..503a431b03 100644 --- a/tests/suite/test_virtual_server_foreign_upstream.py +++ b/tests/suite/test_virtual_server_foreign_upstream.py @@ -7,15 +7,17 @@ create_namespace_with_name_from_yaml, delete_items_from_yaml, delete_namespace, + get_first_pod_name, wait_before_test, - wait_until_all_pods_are_ready, get_first_pod_name, + wait_until_all_pods_are_ready, ) from suite.utils.vs_vsr_resources_utils import ( create_v_s_route_from_yaml, create_virtual_server_from_yaml, delete_v_s_route, delete_virtual_server, - patch_virtual_server_from_yaml, get_vs_nginx_template_conf, + get_vs_nginx_template_conf, + patch_virtual_server_from_yaml, ) from suite.utils.yaml_utils import ( get_first_host_from_yaml, @@ -63,7 +65,7 @@ def virtual_server_foreign_upstream_app_setup( wait_until_all_pods_are_ready(kube_apis.v1, ns_1) wait_until_all_pods_are_ready(kube_apis.v1, ns_2) - + vs_name = create_virtual_server_from_yaml(kube_apis.custom_objects, vs_source, test_namespace) vs_host = get_first_host_from_yaml(vs_source) vs_paths = get_paths_from_vs_yaml(vs_source) @@ -107,7 +109,13 @@ def fin(): indirect=True, ) class TestVirtualServerForeignUpstream: - def test_responses_after_setup(self, kube_apis,ingress_controller_prerequisites, crd_ingress_controller, virtual_server_foreign_upstream_app_setup): + def test_responses_after_setup( + self, + kube_apis, + ingress_controller_prerequisites, + crd_ingress_controller, + virtual_server_foreign_upstream_app_setup, + ): print(f"\nStep 1: initial check") ic_pod_name = get_first_pod_name(kube_apis.v1, ingress_controller_prerequisites.namespace) # log VS conf