test/extended/cli/timeout.go - main - githubmirror/origin

test/extended/cli/timeout.go
71 строка3 KB
xueqzhan
Bump oc request-timeout to deflake tests
14 апр 2026, 15:48
14 апр 2026, 15:48d8f647c
package cli

import (
	g "github.com/onsi/ginkgo/v2"
	o "github.com/onsi/gomega"

	exutil "github.com/openshift/origin/test/extended/util"
	k8simage "k8s.io/kubernetes/test/utils/image"
)

var _ = g.Describe("[sig-cli] oc --request-timeout", func() {
	defer g.GinkgoRecover()

	oc := exutil.NewCLI("oc-request-timeout")

	g.It("works as expected [apigroup:apps.openshift.io]", func() {
		busyBoxImage := k8simage.GetE2EImage(k8simage.BusyBox)
		err := oc.Run("create").Args("deploymentconfig", "testdc", "--image="+busyBoxImage).Execute()
		o.Expect(err).NotTo(o.HaveOccurred())

		out, err := oc.Run("get", "dc/testdc").Args("-w", "-v=5", "--request-timeout=1s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		// timeout is set for both the request and on context in request
		// seek8s.io/client-go/rest/request.go#request so if we get timeout
		// from server or from context it's ok
		o.Expect(out).Should(o.SatisfyAny(o.ContainSubstring("request canceled"), o.ContainSubstring("context deadline exceeded")))

		out, err = oc.Run("get", "dc/testdc").Args("--request-timeout=5s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).To(o.ContainSubstring("testdc"))

		out, err = oc.Run("get", "dc/testdc").Args("--request-timeout=5").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).To(o.ContainSubstring("testdc"))

		out, err = oc.Run("get", "pods").Args("--watch", "-v=5", "--request-timeout=1s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).Should(o.SatisfyAny(
			o.ContainSubstring("request canceled"),
			o.ContainSubstring("context deadline exceeded"),
			o.ContainSubstring("Client.Timeout exceeded while awaiting headers")))
	})

	g.It("works as expected for deployment", func() {
		busyBoxImage := k8simage.GetE2EImage(k8simage.BusyBox)
		err := oc.Run("create").Args("deployment", "testdc", "--image="+busyBoxImage).Execute()
		o.Expect(err).NotTo(o.HaveOccurred())

		out, err := oc.Run("get", "deployment/testdc").Args("-w", "-v=5", "--request-timeout=1s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		// timeout is set for both the request and on context in request
		// seek8s.io/client-go/rest/request.go#request so if we get timeout
		// from server or from context it's ok
		o.Expect(out).Should(o.SatisfyAny(o.ContainSubstring("request canceled"), o.ContainSubstring("context deadline exceeded")))

		out, err = oc.Run("get", "deployment/testdc").Args("--request-timeout=5s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).To(o.ContainSubstring("testdc"))

		out, err = oc.Run("get", "deployment/testdc").Args("--request-timeout=5").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).To(o.ContainSubstring("testdc"))

		out, err = oc.Run("get", "pods").Args("--watch", "-v=5", "--request-timeout=1s").Output()
		o.Expect(err).NotTo(o.HaveOccurred())
		o.Expect(out).Should(o.SatisfyAny(
			o.ContainSubstring("request canceled"),
			o.ContainSubstring("context deadline exceeded"),
			o.ContainSubstring("Client.Timeout exceeded while awaiting headers")))
	})
})