5k pending

Bossett · Sep 6, 2024 · 386fa98 · 386fa98
1 parent 3e81598
commit 386fa98
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/env/limits.ts b/src/env/limits.ts
@@ -48,6 +48,7 @@ const limits = {
   POST_CACHE_MAX_SIZE: 3000,
   MIN_BATCH_WAIT_TIME_MS: 500,
   BATCH_CYCLE_TIMEOUT_MS: 3 * 60 * 1000,
+  FIREHOSE_MAX_PENDING: 5000,
 }
 
 const validateLimits = {

diff --git a/src/firehoseWatcher.ts b/src/firehoseWatcher.ts
@@ -203,7 +203,7 @@ export default async function firehoseWatcher() {
         service: env.SERVICE_ENDPOINT,
         seq: seq,
         timeout: env.limits.MAX_FIREHOSE_DELAY,
-        maxPending: 1000,
+        maxPending: env.limits.FIREHOSE_MAX_PENDING,
         includeTypes: ['app.bsky.feed.post', 'app.bsky.actor.profile'],
       })