Function waitForWorkflowRunStatus

acceptance/acceptance_test.go:200–217

(view func() (string, error), expected string, sleep func(time.Duration))

}

func waitForWorkflowRunStatus(view func() (string, error), expected string, sleep func(time.Duration)) error {
	for attempt := 0; attempt < workflowRunStatusPollAttempts; attempt++ {
		status, err := view()
		if err != nil {
			return err
		}
		if status == expected {
			return nil
		}
		if status == "completed" {
			return fmt.Errorf("workflow run completed before reaching status %q", expected)
		}
		if attempt < workflowRunStatusPollAttempts-1 {
			sleep(workflowRunStatusPollInterval)
		}
	}
	return fmt.Errorf("workflow run did not reach status %q within 60 seconds", expected)
}

func outputForEnvironment(output string) (string, error) {
	if strings.TrimSpace(output) == "" {