mirror of https://github.com/k3s-io/k3s
apiextensions: add storage race TODO in CRD conversion e2e test
parent
9ddc9ccc57
commit
cd0b46874a
|
@ -40,6 +40,7 @@ import (
|
||||||
|
|
||||||
"github.com/onsi/ginkgo"
|
"github.com/onsi/ginkgo"
|
||||||
"github.com/onsi/gomega"
|
"github.com/onsi/gomega"
|
||||||
|
|
||||||
// ensure libs have a chance to initialize
|
// ensure libs have a chance to initialize
|
||||||
_ "github.com/stretchr/testify/assert"
|
_ "github.com/stretchr/testify/assert"
|
||||||
)
|
)
|
||||||
|
@ -386,6 +387,8 @@ func testCRListConversion(f *framework.Framework, testCrd *crd.TestCrd) {
|
||||||
// After changing a CRD, the resources for versions will be re-created that can be result in
|
// After changing a CRD, the resources for versions will be re-created that can be result in
|
||||||
// cancelled connection (e.g. "grpc connection closed" or "context canceled").
|
// cancelled connection (e.g. "grpc connection closed" or "context canceled").
|
||||||
// Just retrying fixes that.
|
// Just retrying fixes that.
|
||||||
|
//
|
||||||
|
// TODO: we have to wait for the storage version to become effective. Storage version changes are not instant.
|
||||||
for i := 0; i < 5; i++ {
|
for i := 0; i < 5; i++ {
|
||||||
_, err = customResourceClients["v1"].Create(crInstance, metav1.CreateOptions{})
|
_, err = customResourceClients["v1"].Create(crInstance, metav1.CreateOptions{})
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
|
Loading…
Reference in New Issue