run prune trash job at 3am UTC daily
This commit is contained in:
@ -50,6 +50,7 @@ import {
|
||||
PROCESS_YOUTUBE_TRANSCRIPT_JOB_NAME,
|
||||
PROCESS_YOUTUBE_VIDEO_JOB_NAME,
|
||||
} from './jobs/process-youtube-video'
|
||||
import { pruneTrashJob, PRUNE_TRASH_JOB } from './jobs/prune_trash'
|
||||
import { refreshAllFeeds } from './jobs/rss/refreshAllFeeds'
|
||||
import { refreshFeed } from './jobs/rss/refreshFeed'
|
||||
import { savePageJob } from './jobs/save_page'
|
||||
@ -214,6 +215,8 @@ export const createWorker = (connection: ConnectionOptions) =>
|
||||
return scoreLibraryItem(job.data)
|
||||
case GENERATE_PREVIEW_CONTENT_JOB:
|
||||
return generatePreviewContent(job.data)
|
||||
case PRUNE_TRASH_JOB:
|
||||
return pruneTrashJob()
|
||||
default:
|
||||
logger.warning(`[queue-processor] unhandled job: ${job.name}`)
|
||||
}
|
||||
@ -248,6 +251,18 @@ const setupCronJobs = async () => {
|
||||
},
|
||||
}
|
||||
)
|
||||
|
||||
await queue.add(
|
||||
PRUNE_TRASH_JOB,
|
||||
{},
|
||||
{
|
||||
priority: getJobPriority(PRUNE_TRASH_JOB),
|
||||
repeat: {
|
||||
// daily at 3am
|
||||
pattern: '0 3 * * *',
|
||||
},
|
||||
}
|
||||
)
|
||||
}
|
||||
|
||||
const main = async () => {
|
||||
|
||||
Reference in New Issue
Block a user