Method getStatus

pkg/async-gateway/service.go:138–171

(id string, apiName string)

}

func (s *service) getStatus(id string, apiName string) (async.Status, error) {
	prefix := async.StoragePath(s.clusterUID, apiName)
	log := s.logger.With(zap.String("id", id))

	// download workload status
	statusPrefixPath := async.StatusPrefixPath(prefix, id)
	log.Debug("checking status", zap.String("path", statusPrefixPath))
	files, err := s.storage.List(statusPrefixPath)
	if err != nil {
		return "", err
	}
	if len(files) == 0 {
		return async.StatusNotFound, nil
	}

	// determine request status
	st := async.StatusInQueue
	for _, file := range files {
		fileStatus := async.Status(file)
		if !fileStatus.Valid() {
			st = fileStatus
			return "", fmt.Errorf("invalid workload status: %s", st)
		}
		if fileStatus == async.StatusInProgress {
			st = fileStatus
		}
		if fileStatus == async.StatusCompleted || fileStatus == async.StatusFailed {
			st = fileStatus
			break
		}
	}

	return st, nil
}