(step PlanStepWait)
| 134 | } |
| 135 | |
| 136 | func (te *TestExecutor) runWaitForDuration(step PlanStepWait) error { |
| 137 | log.Infof("Sleeping for %.0f seconds", step.WaitAmount.Seconds()) |
| 138 | time.Sleep(step.WaitAmount) |
| 139 | return nil |
| 140 | } |
| 141 | |
| 142 | func waitForInjectionCompleted(ctx context.Context, session *chaos_mesh.FaultSession) error { |
| 143 | // First, wait 10 seconds to allow chaos-mesh to inject into the cluster. |