an app.bsky.* indexer

pass context to pumpRepos

Changed files
+3 -3
cmd
backfiller
+3 -3
cmd/backfiller/backfiller.go
···
go bf.Start()
// pump repos
-
go func(bf *backfill.Backfiller) {
-
if err := pumpRepos(context.TODO(), bf); err != nil {
+
go func(ctx context.Context, bf *backfill.Backfiller) {
+
if err := pumpRepos(ctx, bf); err != nil {
sl.Error("failed pumping repos", "err", err)
}
-
}(bf)
+
}(ctx, bf)
// read from the firehose
rsc := events.RepoStreamCallbacks{