Function waitForWorkflow

acceptance/acceptance_test.go:166–182

(list func() ([]string, error), expected string, sleep func(time.Duration))

}

func waitForWorkflow(list func() ([]string, error), expected string, sleep func(time.Duration)) error {
	for attempt := 0; attempt < workflowPollAttempts; attempt++ {
		workflows, err := list()
		if err != nil {
			return err
		}
		for _, workflow := range workflows {
			if workflow == expected {
				return nil
			}
		}
		if attempt < workflowPollAttempts-1 {
			sleep(workflowPollInterval)
		}
	}
	return fmt.Errorf("workflow %q did not register within 60 seconds", expected)
}

func waitForRepositoryReady(check func() (bool, error), sleep func(time.Duration)) error {
	for attempt := 0; attempt < repositoryReadyPollAttempts; attempt++ {