Method retryOperation

go/logic/migrator.go:163–192

retryOperation attempts up to `count` attempts at running given function, exiting as soon as it returns with non-error.

(operation func() error, notFatalHint ...bool)

// retryOperation attempts up to `count` attempts at running given function,
// exiting as soon as it returns with non-error.
func (mgtr *Migrator) retryOperation(operation func() error, notFatalHint ...bool) (err error) {
	maxRetries := int(mgtr.migrationContext.MaxRetries())
	for i := 0; i < maxRetries; i++ {
		if i != 0 {
			// sleep after previous iteration
			RetrySleepFn(1 * time.Second)
		}
		// Check for abort/context cancellation before each retry
		if abortErr := mgtr.checkAbort(); abortErr != nil {
			return abortErr
		}
		err = operation()
		if err == nil {
			return nil
		}
		// Check if this is an unrecoverable error (data consistency issues won't resolve on retry)
		if strings.Contains(err.Error(), "warnings detected") {
			if len(notFatalHint) == 0 {
				_ = base.SendWithContext(mgtr.migrationContext.GetContext(), mgtr.migrationContext.PanicAbort, err)
			}
			return err
		}
		// there's an error. Let's try again.
	}
	if len(notFatalHint) == 0 {
		// Use helper to prevent deadlock if listenOnPanicAbort already exited
		_ = base.SendWithContext(mgtr.migrationContext.GetContext(), mgtr.migrationContext.PanicAbort, err)
	}
	return err
}

// `retryOperationWithExponentialBackoff` attempts running given function, waiting 2^(n-1)
// seconds between each attempt, where `n` is the running number of attempts. Exits