mirror of
https://github.com/optim-enterprises-bv/kubernetes.git
synced 2025-11-03 11:48:15 +00:00
Merge pull request #123588 from pohly/scheduler-perf-any-cleanup
scheduler_perf: automatically delete created objects
This commit is contained in:
@@ -21,6 +21,7 @@ import (
|
||||
"fmt"
|
||||
"time"
|
||||
|
||||
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
||||
"k8s.io/apimachinery/pkg/api/meta"
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
||||
@@ -113,6 +114,18 @@ func (c *createAny) run(tCtx ktesting.TContext) {
|
||||
}
|
||||
_, err = resourceClient.Create(tCtx, obj, options)
|
||||
}
|
||||
if err == nil && shouldCleanup(tCtx) {
|
||||
tCtx.CleanupCtx(func(tCtx ktesting.TContext) {
|
||||
del := resourceClient.Delete
|
||||
if mapping.Scope.Name() != meta.RESTScopeNameNamespace {
|
||||
del = resourceClient.Namespace(c.Namespace).Delete
|
||||
}
|
||||
err := del(tCtx, obj.GetName(), metav1.DeleteOptions{})
|
||||
if !apierrors.IsNotFound(err) {
|
||||
tCtx.ExpectNoError(err, fmt.Sprintf("deleting %s.%s %s", obj.GetKind(), obj.GetAPIVersion(), klog.KObj(obj)))
|
||||
}
|
||||
})
|
||||
}
|
||||
return err
|
||||
}
|
||||
// Retry, some errors (like CRD just created and type not ready for use yet) are temporary.
|
||||
|
||||
Reference in New Issue
Block a user