awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-10-07 18:27:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update dynamic-secret-lease-queue.ts

Browse Source
This commit is contained in:
Daniel Hougaard
2025-11-25 10:25:34 -08:00
parent d71eac815d
commit 0b8e39713d
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/ee/services/dynamic-secret-lease/dynamic-secret-lease-queue.ts
+2 -3
View File
@@ -82,8 +82,8 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
{ leaseId }, { leaseId },
{ {
singletonKey: `${leaseId}-retry`, // avoid conflicts with scheduled revocation singletonKey: `${leaseId}-retry`, // avoid conflicts with scheduled revocation
retryDelay: Math.floor(applyJitter(3_600_000 * 4) / 1000), // retry every 4 hours with 20% +- jitter retryDelay: Math.floor(applyJitter(3_600_000 * 4) / 1000), // retry every 4 hours with 20% +- jitter (convert ms to seconds for pgboss)
retryLimit: 20, // we dont want it to ever hit the limit, we want the expireInHours to take effect. retryLimit: 10, // we dont want it to ever hit the limit, we want the expireInHours to take effect.
expireInHours: 23, // if we set it to 24 hours, pgboss will complain that the expireIn is too high expireInHours: 23, // if we set it to 24 hours, pgboss will complain that the expireIn is too high
deadLetter: QueueName.DynamicSecretRevocationFailedRetry // if all fails, we will send a notification to the user deadLetter: QueueName.DynamicSecretRevocationFailedRetry // if all fails, we will send a notification to the user
} }
@@ -192,7 +192,6 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
}); });
// if revocation fails, we should stop the job and queue a new job to retry the revocation at a later time. // if revocation fails, we should stop the job and queue a new job to retry the revocation at a later time.
await queueService.stopJobById(QueueName.DynamicSecretRevocation, jobId);
await queueService.stopJobByIdPg(QueueName.DynamicSecretRevocation, jobId); await queueService.stopJobByIdPg(QueueName.DynamicSecretRevocation, jobId);
await queueFailedRevocation(leaseId); await queueFailedRevocation(leaseId);
} }