diff --git a/backend/src/services/identity-access-token/identity-access-token-dal.ts b/backend/src/services/identity-access-token/identity-access-token-dal.ts index 448f2dd46..ee89fbdd8 100644 --- a/backend/src/services/identity-access-token/identity-access-token-dal.ts +++ b/backend/src/services/identity-access-token/identity-access-token-dal.ts @@ -48,7 +48,7 @@ export const identityAccessTokenDALFactory = (db: TDbClient) => { .where("accessTokenNumUsesLimit", ">", 0) .andWhere( "accessTokenNumUses", - ">", + ">=", db.ref("accessTokenNumUsesLimit").withSchema(TableName.IdentityAccessToken) ); }) @@ -76,7 +76,7 @@ export const identityAccessTokenDALFactory = (db: TDbClient) => { .delete(); return await docs; } catch (error) { - throw new DatabaseError({ error, name: "IdentityAccesTokenPrune" }); + throw new DatabaseError({ error, name: "IdentityAccessTokenPrune" }); } }; diff --git a/backend/src/services/resource-cleanup/resource-cleanup-queue.ts b/backend/src/services/resource-cleanup/resource-cleanup-queue.ts index 3c8bcb1f7..a5e240839 100644 --- a/backend/src/services/resource-cleanup/resource-cleanup-queue.ts +++ b/backend/src/services/resource-cleanup/resource-cleanup-queue.ts @@ -44,7 +44,10 @@ export const dailyResourceCleanUpQueueServiceFactory = ({ await queueService.queue(QueueName.DailyResourceCleanUp, QueueJobs.DailyResourceCleanUp, undefined, { delay: 5000, jobId: QueueName.DailyResourceCleanUp, - repeat: { pattern: "0 0 * * *", utc: true } + repeat: { + every: 10000 + // limit: 100, + } }); };