awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-09-22 13:39:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: addressed review comments

Browse Source
This commit is contained in:
=
2025-06-23 23:37:51 +05:30
parent e5a967b918
commit f5d769fa05
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/ee/services/dynamic-secret-lease/dynamic-secret-lease-queue.ts
View File

@@ -64,6 +64,7 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
};
const unsetLeaseRevocation = async (leaseId: string) => {
await queueService.stopJobById(QueueName.DynamicSecretRevocation, leaseId);
await queueService.stopJobByIdPg(QueueName.DynamicSecretRevocation, leaseId);
};
@@ -169,6 +170,7 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
if (error instanceof DisableRotationErrors) {
if (jobId) {
await queueService.stopRepeatableJobByJobId(QueueName.DynamicSecretRevocation, jobId);
await queueService.stopJobByIdPg(QueueName.DynamicSecretRevocation, jobId);
}
}
// propogate to next part
@@ -187,8 +189,8 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
await $dynamicSecretQueueJob(job.name, job.id, job.data);
},
{
workerCount: 2,
pollingIntervalSeconds: 30
workerCount: 5,
pollingIntervalSeconds: 1
}
);
@@ -198,8 +200,8 @@ export const dynamicSecretLeaseQueueServiceFactory = ({
await $dynamicSecretQueueJob(job.name, job.id, job.data);
},
{
workerCount: 2,
pollingIntervalSeconds: 5
workerCount: 1,
pollingIntervalSeconds: 1
}
);
};