misty.cafe/mistykey
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

adjust job scheduler timings

Browse source
This commit is contained in:
Hazelnoot 2025-11-07 02:51:58 -05:00
parent 26db8cb96e
commit 10a9e423d9
1 changed files with 19 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

37
packages/backend/src/core/QueueService.ts
View file

@ -91,7 +91,7 @@ export class QueueService implements OnModuleInit {
await this.systemQueue.upsertJobScheduler(
'resyncCharts-scheduler',
{ pattern: '10 0 * * *' }, // every day at 00:10 (avoid tickCharts)
{ pattern: '20 0 * * *' }, // every day at 00:20 (wait for tickCharts)
{
name: 'resyncCharts',
opts: {
@ -102,7 +102,7 @@ export class QueueService implements OnModuleInit {
await this.systemQueue.upsertJobScheduler(
'cleanCharts-scheduler',
{ pattern: '30 0 * * *' }, // every day at 00:30 (wait for resyncCharts)
{ pattern: '40 0 * * *' }, // every day at 00:40 (wait for resyncCharts)
{
name: 'cleanCharts',
opts: {
@ -113,7 +113,7 @@ export class QueueService implements OnModuleInit {
await this.systemQueue.upsertJobScheduler(
'aggregateRetention-scheduler',
{ pattern: '5 1 * * *' }, // every day at 01:05 (avoid chart jobs)
{ pattern: '0 1 * * *' }, // every day at 01:00
{
name: 'aggregateRetention',
opts: {
@ -124,7 +124,7 @@ export class QueueService implements OnModuleInit {
await this.systemQueue.upsertJobScheduler(
'clean-scheduler',
{ pattern: '10 1 * * *' }, // every day at 01:10 (avoid aggregateRetention)
{ pattern: '10 1 * * *' }, // every day at 01:10 (wait for aggregateRetention)
{
name: 'clean',
opts: {
@ -144,20 +144,9 @@ export class QueueService implements OnModuleInit {
},
});
await this.systemQueue.upsertJobScheduler(
'cleanupApLogs-scheduler',
{ pattern: '*/10 * * *' }, // every 10 minutes
{
name: 'cleanupApLogs',
opts: {
removeOnComplete: 10,
removeOnFail: 30,
},
});
await this.systemQueue.upsertJobScheduler(
'bakeBufferedReactions-scheduler',
{ pattern: '20 1 * * *' }, // every day at 01:20 (avoid clean)
{ pattern: '20 1 * * *' }, // every day at 01:40 (wait for clean)
{
name: 'bakeBufferedReactions',
opts: {
@ -169,7 +158,7 @@ export class QueueService implements OnModuleInit {
await this.systemQueue.upsertJobScheduler(
'checkModeratorsActivity-scheduler',
// 毎時30分に起動
{ pattern: '30 1 * * *' }, // every day at 01:30 (avoid cleanupApLogs)
{ pattern: '30 * * * *' }, // every hour at :30
{
name: 'checkModeratorsActivity',
opts: {
@ -178,9 +167,20 @@ export class QueueService implements OnModuleInit {
},
});
await this.systemQueue.upsertJobScheduler(
'cleanupApLogs-scheduler',
{ pattern: '*/10 * * *' }, // every 10 minutes
{
name: 'cleanupApLogs',
opts: {
removeOnComplete: 10,
removeOnFail: 30,
},
});
await this.systemQueue.upsertJobScheduler(
'hibernateUsers-scheduler',
{ pattern: '40 1 * * *' }, // every day at 01:40 (avoid checkModeratorsActivity)
{ pattern: '30 1 * * *' }, // every day at 01:30 (avoid bakeBufferedReactions)
{
name: 'hibernateUsers',
opts: {
@ -189,6 +189,7 @@ export class QueueService implements OnModuleInit {
},
});
// Slot '40 1 * * *' is available for future work
// Slot '50 1 * * *' is available for future work
}