bringing back min delay - boosting lookahead

Bossett · Sep 9, 2024 · 78cfab1 · 78cfab1
1 parent 4a283df
commit 78cfab1
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/labelEmitter.ts b/src/labelEmitter.ts
@@ -18,8 +18,7 @@ type Event = {
 
 const waitTime =
   env.limits.PDS_LIMIT_MAX_CONCURRENT /
-    (env.limits.PDS_LIMIT_MAX_RATE / env.limits.PDS_LIMIT_RATE_INTERVAL_MS) +
-  1000
+  (env.limits.PDS_LIMIT_MAX_RATE / env.limits.PDS_LIMIT_RATE_INTERVAL_MS)
 
 export default async function labelEmitter() {
   do {
@@ -38,7 +37,7 @@ export default async function labelEmitter() {
         action: true,
         unixtimescheduled: true,
       },
-      limit: 2 * Math.floor(env.limits.PDS_LIMIT_MAX_CONCURRENT),
+      limit: 10 * Math.floor(env.limits.PDS_LIMIT_MAX_CONCURRENT),
     })
     if (events.length > 0) {
       const [completedEvents, groupedEvents, eventLog] = await processEvents(