Method submitRequest

pkg/dequeuer/batch_handler.go:114–144

(messageBody string, isOnJobComplete bool)

}

func (h *BatchMessageHandler) submitRequest(messageBody string, isOnJobComplete bool) error {
	targetURL := h.config.TargetURL
	if isOnJobComplete {
		targetURL = urls.Join(targetURL, "/on-job-complete")
	}

	req, err := http.NewRequest(http.MethodPost, targetURL, bytes.NewBuffer([]byte(messageBody)))
	if err != nil {
		return errors.WithStack(err)
	}

	req.Header.Set("Content-Type", "application/json")
	req.Header.Set(CortexJobIDHeader, h.config.JobID)
	response, err := h.httpClient.Do(req)
	if err != nil {
		return ErrorUserContainerNotReachable(err)
	}
	defer func() {
		_ = response.Body.Close()
	}()

	if response.StatusCode == http.StatusNotFound && isOnJobComplete {
		return nil
	}

	if response.StatusCode != http.StatusOK {
		return ErrorUserContainerResponseStatusCode(response.StatusCode)
	}

	return nil
}

func (h *BatchMessageHandler) handleBatch(message *sqs.Message) error {
	h.log.Infow("processing batch", "id", *message.MessageId)