pepepper/fluxer
1
0 Fork 0
mirror of https://github.com/fluxerapp/fluxer synced 2026-10-18 05:25:40 +09:00
Code Issues Packages Projects Releases Wiki Activity

perf(worker): skip the bunny purge cron when purging is off (#2208)

Browse Source
This commit is contained in:
Hampus authored and GitHub committed 2026-08-31 00:14:39 +02:00
1 parent b163888cf3
commit a96d9cd075
1 file changed
+8 -2
Download Patch File Download Diff File Expand all files Collapse all files
fluxer_api/src/api/worker/WorkerMain.ts
+8 -2
View File
@@ -44,7 +44,9 @@ const SEARCH_REQUIRED_TASKS = new Set<string>([
function registerCronJobs(cron: CronScheduler): void { function registerCronJobs(cron: CronScheduler): void {
cron.upsert('processAssetDeletionQueue', 'processAssetDeletionQueue', {}, '0 */5 * * * *', {ledger: false}); cron.upsert('processAssetDeletionQueue', 'processAssetDeletionQueue', {}, '0 */5 * * * *', {ledger: false});
cron.upsert('processBunnyPurgeQueue', 'processBunnyPurgeQueue', {}, '*/10 * * * * *', {ledger: false}); if (Config.bunny.purgeEnabled) {
cron.upsert('processBunnyPurgeQueue', 'processBunnyPurgeQueue', {}, '*/10 * * * * *', {ledger: false});
}
cron.upsert('processPendingBulkMessageDeletions', 'processPendingBulkMessageDeletions', {}, '0 */10 * * * *', { cron.upsert('processPendingBulkMessageDeletions', 'processPendingBulkMessageDeletions', {}, '0 */10 * * * *', {
ledger: false, ledger: false,
}); });
@@ -73,7 +75,11 @@ function registerCronJobs(cron: CronScheduler): void {
} }
cron.upsert('flushUserActivityBuffer', 'flushUserActivityBuffer', {}, '*/10 * * * * *', {ledger: false}); cron.upsert('flushUserActivityBuffer', 'flushUserActivityBuffer', {}, '*/10 * * * * *', {ledger: false});
Logger.info( Logger.info(
{blocklistFeeds: Config.blocklistFeeds.enabled, selfHosted: Config.instance.selfHosted}, {
blocklistFeeds: Config.blocklistFeeds.enabled,
bunnyPurge: Config.bunny.purgeEnabled,
selfHosted: Config.instance.selfHosted,
},
'Cron jobs registered successfully', 'Cron jobs registered successfully',
); );
} }