Function waitForRepositoryReady

acceptance/acceptance_test.go:184–198

(check func() (bool, error), sleep func(time.Duration))

}

func waitForRepositoryReady(check func() (bool, error), sleep func(time.Duration)) error {
	for attempt := 0; attempt < repositoryReadyPollAttempts; attempt++ {
		ready, err := check()
		if err != nil {
			return err
		}
		if ready {
			return nil
		}
		if attempt < repositoryReadyPollAttempts-1 {
			sleep(repositoryReadyPollInterval)
		}
	}
	return errors.New("repository did not finish initializing within 30 seconds")
}

func waitForWorkflowRunStatus(view func() (string, error), expected string, sleep func(time.Duration)) error {
	for attempt := 0; attempt < workflowRunStatusPollAttempts; attempt++ {