diff --git a/backfill/backfill.go b/backfill/backfill.go index 2199147cb..14d6741a9 100644 --- a/backfill/backfill.go +++ b/backfill/backfill.go @@ -101,7 +101,7 @@ func DefaultBackfillOptions() *BackfillOptions { ParallelRecordCreates: 100, NSIDFilter: "", SyncRequestsPerSecond: 2, - CheckoutPath: "https://bsky.social/xrpc/com.atproto.sync.getCheckout", + CheckoutPath: "https://bsky.social/xrpc/com.atproto.sync.getRepo", } } @@ -261,7 +261,7 @@ func (b *Backfiller) BackfillRepo(ctx context.Context, job Job) { // GET and CAR decode the body client := &http.Client{ Transport: otelhttp.NewTransport(http.DefaultTransport), - Timeout: 120 * time.Second, + Timeout: 600 * time.Second, } req, err := http.NewRequestWithContext(ctx, "GET", url, nil) if err != nil { diff --git a/search/server.go b/search/server.go index a69e6f4b3..8752b9612 100644 --- a/search/server.go +++ b/search/server.go @@ -93,6 +93,7 @@ func NewServer(db *gorm.DB, escli *es.Client, dir identity.Directory, config Con } else { opts.SyncRequestsPerSecond = 8 } + opts.CheckoutPath = fmt.Sprintf("%s/xrpc/com.atproto.sync.getRepo", bgshttp) if config.IndexMaxConcurrency > 0 { opts.ParallelRecordCreates = config.IndexMaxConcurrency } else {