Method retryCompleteOp

modules/livestore/live_store_background.go:162–179

(op *completeOp, span oteltrace.Span, msg string, err error)

}

func (s *LiveStore) retryCompleteOp(op *completeOp, span oteltrace.Span, msg string, err error) {
	level.Error(s.logger).Log("msg", msg, "tenant", op.tenantID, "block", op.blockID, "err", err)
	observeFailedOp(op)
	span.RecordError(err)

	delay := op.backoff()
	op.at = time.Now().Add(delay)

	metricCompletionRetries.Inc()

	go func() {
		time.Sleep(delay)

		if err := s.requeueOp(op); err != nil {
			_ = level.Error(s.logger).Log("msg", "failed to requeue block for flushing", "tenant", op.tenantID, "block", op.blockID, "err", err)
		}
	}()
}

func (s *LiveStore) startPerTenantCutToWalLoop(inst *instance) {
	s.cutToWalWg.Add(1)