Method executeWithRetry

pkgs/cmd/exec.go:95–122

executeWithRetry calls doExecute, retrying up to retryMaxAttempts times on failure.

(output io.Writer)

// executeWithRetry calls doExecute, retrying up to retryMaxAttempts times on failure.
func (e *executor) executeWithRetry(output io.Writer) error {
	if e.retryMaxAttempts <= 1 {
		return e.doExecute(output)
	}

	var lastErr error
	for attempt := 1; attempt <= e.retryMaxAttempts; attempt++ {
		if attempt > 1 {
			// Reset buffer, to make sure the output buffer is clean after new retry.
			if r, ok := output.(resetable); ok {
				r.Reset()
			}
		}
		lastErr = e.doExecute(output)
		if lastErr == nil {
			return nil
		}

		color.Printf(color.Warning, "Attempted (%d/%d): %v\n", attempt, e.retryMaxAttempts, lastErr)
		if attempt < e.retryMaxAttempts {
			time.Sleep(time.Duration(attempt) * time.Second)
		}
	}

	// Show mesage without "[]".
	e.title = strings.Trim(e.title, "[]")
	return fmt.Errorf("%s failed after %d attempts -> %w", e.title, e.retryMaxAttempts, lastErr)
}

// createLogFile creates and initializes a log file with environment variables and command info.
func (e *executor) createLogFile(cmd *exec.Cmd) (*os.File, error) {