this repo has no description
set a longer timeout for our own PDS (#336)
authored by
Whyrusleeping
and committed by
GitHub
3bda8728
1f761b3c
+8
-5
+2
-2
bgs/bgs.go
+2
-2
bgs/bgs.go
···
749
749
rebasesCounter.WithLabelValues(host.Host).Add(1)
750
750
ai, err := bgs.Index.LookupUser(ctx, u.ID)
751
751
if err != nil {
752
-
return err
752
+
return fmt.Errorf("failed to look up user (slow path): %w", err)
753
753
}
754
754
755
755
// TODO: we currently do not handle events that get queued up
···
769
769
if errors.Is(err, carstore.ErrRepoBaseMismatch) || ipld.IsNotFound(err) {
770
770
ai, err := bgs.Index.LookupUser(ctx, u.ID)
771
771
if err != nil {
772
-
return err
772
+
return fmt.Errorf("failed to look up user (err case): %w", err)
773
773
}
774
774
775
775
span.SetAttributes(attribute.Bool("catchup_queue", true))
+6
-3
cmd/bigsky/main.go
+6
-3
cmd/bigsky/main.go
···
283
283
284
284
rlskip := os.Getenv("BSKY_SOCIAL_RATE_LIMIT_SKIP")
285
285
ix.ApplyPDSClientSettings = func(c *xrpc.Client) {
286
-
if c.Host == "https://bsky.social" && rlskip != "" {
287
-
c.Headers = map[string]string{
288
-
"x-ratelimit-bypass": rlskip,
286
+
if c.Host == "https://bsky.social" {
287
+
c.Client.Timeout = time.Minute * 30
288
+
if rlskip != "" {
289
+
c.Headers = map[string]string{
290
+
"x-ratelimit-bypass": rlskip,
291
+
}
289
292
}
290
293
}
291
294
}