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

Improve dailyResourceCleanUpQueue error message

Browse Source
This commit is contained in:
Carlos Monastyrski
2025-08-11 12:06:35 -07:00
parent 3f7862a345
commit 86fbe5cc24
1 changed files with 22 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/services/resource-cleanup/resource-cleanup-queue.ts
+22 -13
View File
@@ -52,19 +52,24 @@ export const dailyResourceCleanUpQueueServiceFactory = ({
await queueService.startPg<QueueName.DailyResourceCleanUp>( await queueService.startPg<QueueName.DailyResourceCleanUp>(
QueueJobs.DailyResourceCleanUp, QueueJobs.DailyResourceCleanUp,
async () => { async () => {
logger.info(`${QueueName.DailyResourceCleanUp}: queue task started`); try {
await identityAccessTokenDAL.removeExpiredTokens(); logger.info(`${QueueName.DailyResourceCleanUp}: queue task started`);
await identityUniversalAuthClientSecretDAL.removeExpiredClientSecrets(); await identityAccessTokenDAL.removeExpiredTokens();
await secretSharingDAL.pruneExpiredSharedSecrets(); await identityUniversalAuthClientSecretDAL.removeExpiredClientSecrets();
await secretSharingDAL.pruneExpiredSecretRequests(); await secretSharingDAL.pruneExpiredSharedSecrets();
await snapshotDAL.pruneExcessSnapshots(); await secretSharingDAL.pruneExpiredSecretRequests();
await secretVersionDAL.pruneExcessVersions(); await snapshotDAL.pruneExcessSnapshots();
await secretVersionV2DAL.pruneExcessVersions(); await secretVersionDAL.pruneExcessVersions();
await secretFolderVersionDAL.pruneExcessVersions(); await secretVersionV2DAL.pruneExcessVersions();
await serviceTokenService.notifyExpiringTokens(); await secretFolderVersionDAL.pruneExcessVersions();
await orgService.notifyInvitedUsers(); await serviceTokenService.notifyExpiringTokens();
await auditLogDAL.pruneAuditLog(); await orgService.notifyInvitedUsers();
logger.info(`${QueueName.DailyResourceCleanUp}: queue task completed`); await auditLogDAL.pruneAuditLog();
logger.info(`${QueueName.DailyResourceCleanUp}: queue task completed`);
} catch (error) {
logger.error(error, `${QueueName.DailyResourceCleanUp}: resource cleanup failed`);
throw error;
}
}, },
{ {
batchSize: 1, batchSize: 1,
@@ -78,6 +83,10 @@ export const dailyResourceCleanUpQueueServiceFactory = ({
undefined, undefined,
{ tz: "UTC" } { tz: "UTC" }
); );
queueService.listen(QueueName.DailyResourceCleanUp, "failed", (_, err) => {
logger.error(err, `${QueueName.DailyResourceCleanUp}: resource cleanup failed`);
});
}; };
return { return {