diff --git a/pkg/indexerlookup/candidatesource.go b/pkg/indexerlookup/candidatesource.go
index c9155189..b47679f2 100644
--- a/pkg/indexerlookup/candidatesource.go
+++ b/pkg/indexerlookup/candidatesource.go
@@ -37,30 +37,6 @@ func NewCandidateSource(o ...Option) (*IndexerCandidateSource, error) {
 	}, nil
 }
 
-func (idxf *IndexerCandidateSource) sendJsonRequest(req *http.Request) (*model.FindResponse, error) {
-	req.Header.Set("Accept", "application/json")
-	logger.Debugw("sending outgoing request", "url", req.URL, "accept", req.Header.Get("Accept"))
-	resp, err := idxf.httpClient.Do(req)
-	if err != nil {
-		logger.Debugw("Failed to perform json lookup", "err", err)
-		return nil, err
-	}
-	switch resp.StatusCode {
-	case http.StatusOK:
-		defer resp.Body.Close()
-		b, err := io.ReadAll(resp.Body)
-		if err != nil {
-			logger.Debugw("Failed to read response JSON response body", "err", err)
-			return nil, err
-		}
-		return model.UnmarshalFindResponse(b)
-	case http.StatusNotFound:
-		return &model.FindResponse{}, nil
-	default:
-		return nil, fmt.Errorf("batch find query failed: %s", http.StatusText(resp.StatusCode))
-	}
-}
-
 func decodeMetadata(pr model.ProviderResult) (metadata.Metadata, error) {
 	if len(pr.Metadata) == 0 {
 		return metadata.Metadata{}, errors.New("no metadata")
diff --git a/pkg/retriever/assignablecandidatefinder.go b/pkg/retriever/assignablecandidatefinder.go
index 6aedce7b..eaa267a6 100644
--- a/pkg/retriever/assignablecandidatefinder.go
+++ b/pkg/retriever/assignablecandidatefinder.go
@@ -10,9 +10,6 @@ import (
 	"github.com/filecoin-project/lassie/pkg/events"
 	"github.com/filecoin-project/lassie/pkg/internal/candidatebuffer"
 	"github.com/filecoin-project/lassie/pkg/types"
-	"github.com/ipfs/go-cid"
-	"github.com/ipni/go-libipni/metadata"
-	"github.com/libp2p/go-libp2p/core/peer"
 )
 
 type FilterIndexerCandidate func(types.RetrievalCandidate) (bool, types.RetrievalCandidate)
@@ -82,15 +79,3 @@ func (acf AssignableCandidateFinder) FindCandidates(ctx context.Context, request
 	}
 	return nil
 }
-
-func sendFixedPeers(requestCid cid.Cid, fixedPeers []peer.AddrInfo, onNextCandidate candidatebuffer.OnNextCandidate) error {
-	md := metadata.Default.New(&metadata.GraphsyncFilecoinV1{}, &metadata.Bitswap{}, &metadata.IpfsGatewayHttp{})
-	for _, fixedPeer := range fixedPeers {
-		onNextCandidate(types.RetrievalCandidate{
-			MinerPeer: fixedPeer,
-			RootCid:   requestCid,
-			Metadata:  md,
-		})
-	}
-	return nil
-}