Resume rate limiting run executions, but reschedule throttled jobs 10…

… seconds into the future instead of their original run_at, which will help with database load
triggerdotdev · May 10, 2024 · 2e02743 · 2e02743
1 parent 1642fd7
commit 2e02743
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/apps/webapp/app/platform/zodWorker.server.ts b/apps/webapp/app/platform/zodWorker.server.ts
@@ -468,7 +468,7 @@ export class ZodWorker<TMessageCatalog extends MessageCatalogSchema> {
     this.#logDebug("Rescheduling task", { payload, job: helpers.job });
 
     await this.enqueue(helpers.job.task_identifier, payload, {
-      runAt: helpers.job.run_at,
+      runAt: new Date(Date.now() + 1000 * 10),
       queueName: await this.#getQueueName(helpers.job.job_queue_id),
       priority: helpers.job.priority,
       jobKey: helpers.job.key ?? undefined,

diff --git a/apps/webapp/app/services/worker.server.ts b/apps/webapp/app/services/worker.server.ts
@@ -590,7 +590,7 @@ function getExecutionWorkerQueue() {
     },
     shutdownTimeoutInMs: env.GRACEFUL_SHUTDOWN_TIMEOUT,
     schema: executionWorkerCatalog,
-    // rateLimiter: executionRateLimiter,
+    rateLimiter: executionRateLimiter,
     tasks: {
       performRunExecutionV2: {
         priority: 0, // smaller number = higher priority