diff --git a/apps/api/src/lib/job-priority.ts b/apps/api/src/lib/job-priority.ts index fdea28b9..00bf9fa4 100644 --- a/apps/api/src/lib/job-priority.ts +++ b/apps/api/src/lib/job-priority.ts @@ -11,6 +11,8 @@ export async function addJobPriority(team_id, job_id) { // Add scrape job id to the set await redisConnection.sadd(setKey, job_id); + await redisConnection.expire(setKey, 60); + } catch (e) { Logger.error(`Add job priority (sadd) failed: ${team_id}, ${job_id}`); }