Method pollBlock

tempodb/blocklist/poller.go:461–506

(
	ctx context.Context,
	tenantID string,
	blockID uuid.UUID,
	compacted bool,
)

}

func (p *Poller) pollBlock(
	ctx context.Context,
	tenantID string,
	blockID uuid.UUID,
	compacted bool,
) (*backend.BlockMeta, *backend.CompactedBlockMeta, error) {
	derivedCtx, span := tracer.Start(ctx, "Poller.pollBlock")
	defer span.End()
	var err error

	span.SetAttributes(attribute.String("tenant", tenantID))
	span.SetAttributes(attribute.String("block", blockID.String()))

	var blockMeta *backend.BlockMeta
	var compactedBlockMeta *backend.CompactedBlockMeta

	if !compacted && p.cfg.SkipNoCompactBlocks {
		noCompact, flagErr := p.reader.HasNoCompactFlag(derivedCtx, blockID, tenantID)
		if flagErr != nil {
			return nil, nil, fmt.Errorf("failed to check nocompact flag: %w", flagErr)
		}
		if noCompact {
			return nil, nil, nil
		}
	}
	if !compacted {
		blockMeta, err = p.reader.BlockMeta(derivedCtx, blockID, tenantID)
	}
	// if the normal meta doesn't exist maybe it's compacted.
	if errors.Is(err, backend.ErrDoesNotExist) || compacted {
		blockMeta = nil
		compactedBlockMeta, err = p.compactor.CompactedBlockMeta(blockID, tenantID)
	}

	// blocks in intermediate states may not have a compacted or normal block meta.
	//   this is not necessarily an error, just bail out
	if errors.Is(err, backend.ErrDoesNotExist) {
		return nil, nil, nil
	}

	if err != nil {
		return nil, nil, err
	}

	return blockMeta, compactedBlockMeta, nil
}

// tenantIndexBuilder returns true if this poller owns this tenant
func (p *Poller) tenantIndexBuilder(tenant string) bool {