Skip to content

Commit

Permalink
Speed up testing waits for validation
Browse files Browse the repository at this point in the history
  • Loading branch information
falfaroc committed Sep 24, 2024
1 parent abab23e commit fa2d0e0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tests/e2e/steps/steps_def.go
Original file line number Diff line number Diff line change
Expand Up @@ -342,7 +342,7 @@ func (step *Step) deleteCustomResource(res Resource, crNumStr string) error {
func (step *Step) validateCustomResourceStatus(res Resource, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
cr := res.CustomResource[crNum-1].(csmv1.ContainerStorageModule)
time.Sleep(60 * time.Second)
time.Sleep(20 * time.Second)
found := new(csmv1.ContainerStorageModule)
err := step.ctrlClient.Get(context.TODO(), client.ObjectKey{
Namespace: cr.Namespace,
Expand All @@ -360,13 +360,13 @@ func (step *Step) validateCustomResourceStatus(res Resource, crNumStr string) er

func (step *Step) validateDriverInstalled(res Resource, driverName string, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
time.Sleep(60 * time.Second)
time.Sleep(20 * time.Second)
return checkAllRunningPods(context.TODO(), res.CustomResource[crNum-1].(csmv1.ContainerStorageModule).Namespace, step.clientSet)
}

func (step *Step) validateDriverNotInstalled(res Resource, driverName string, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
time.Sleep(60 * time.Second)
time.Sleep(20 * time.Second)
return checkNoRunningPods(context.TODO(), res.CustomResource[crNum-1].(csmv1.ContainerStorageModule).Namespace, step.clientSet)
}

Expand All @@ -393,7 +393,7 @@ func (step *Step) removeNodeLabel(res Resource, label string) error {
func (step *Step) validateModuleInstalled(res Resource, module string, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
cr := res.CustomResource[crNum-1].(csmv1.ContainerStorageModule)
time.Sleep(60 * time.Second)
time.Sleep(10 * time.Second)
found := new(csmv1.ContainerStorageModule)
if err := step.ctrlClient.Get(context.TODO(), client.ObjectKey{
Namespace: cr.Namespace,
Expand Down Expand Up @@ -438,7 +438,7 @@ func (step *Step) validateModuleInstalled(res Resource, module string, crNumStr
func (step *Step) validateModuleNotInstalled(res Resource, module string, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
cr := res.CustomResource[crNum-1].(csmv1.ContainerStorageModule)
time.Sleep(60 * time.Second)
time.Sleep(10 * time.Second)
found := new(csmv1.ContainerStorageModule)
if err := step.ctrlClient.Get(context.TODO(), client.ObjectKey{
Namespace: cr.Namespace,
Expand Down Expand Up @@ -905,7 +905,7 @@ func (step *Step) runCustomTest(res Resource) error {
func (step *Step) enableModule(res Resource, module string, crNumStr string) error {
crNum, _ := strconv.Atoi(crNumStr)
cr := res.CustomResource[crNum-1].(csmv1.ContainerStorageModule)
time.Sleep(60 * time.Second)
time.Sleep(15 * time.Second)
found := new(csmv1.ContainerStorageModule)
if err := step.ctrlClient.Get(context.TODO(), client.ObjectKey{
Namespace: cr.Namespace,
Expand Down

0 comments on commit fa2d0e0

Please sign in to comment.