oscar-surf/misskey
oscar-surf/misskey
0
0
Fork 0
Code Issues Activity

fix: queue running problem

Browse source
This commit is contained in:
아르페 2024-02-16 15:04:18 +09:00 • committed by 무라쿠모
parent de6db7aefc
commit 5d0012ceac
No known key found for this signature in database
GPG key ID: 139D6573F92DA9F7
4 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -72,7 +72,7 @@ export class QueueService {
this.systemQueue.add('autoNoteRemoval', { this.systemQueue.add('autoNoteRemoval', {
}, { }, {
repeat: { pattern: '* */10 * * *' }, repeat: { pattern: '*/10 * * * *' },
removeOnComplete: true, removeOnComplete: true,
}); });
} }

2
packages/backend/src/queue/QueueProcessorModule.ts
View file

@ -40,6 +40,7 @@ import { TickChartsProcessorService } from './processors/TickChartsProcessorServ
import { AggregateRetentionProcessorService } from './processors/AggregateRetentionProcessorService.js'; import { AggregateRetentionProcessorService } from './processors/AggregateRetentionProcessorService.js';
import { ExportFavoritesProcessorService } from './processors/ExportFavoritesProcessorService.js'; import { ExportFavoritesProcessorService } from './processors/ExportFavoritesProcessorService.js';
import { RelationshipProcessorService } from './processors/RelationshipProcessorService.js'; import { RelationshipProcessorService } from './processors/RelationshipProcessorService.js';
import { AutoNoteRemovalProcessorService } from './processors/AutoNoteRemovalProcessorService.js';
@Module({ @Module({
imports: [ imports: [
@ -80,6 +81,7 @@ import { RelationshipProcessorService } from './processors/RelationshipProcessor
DeliverProcessorService, DeliverProcessorService,
InboxProcessorService, InboxProcessorService,
AggregateRetentionProcessorService, AggregateRetentionProcessorService,
AutoNoteRemovalProcessorService,
QueueProcessorService, QueueProcessorService,
], ],
exports: [ exports: [

2
packages/backend/src/queue/QueueProcessorService.ts
View file

@ -41,7 +41,7 @@ import { CleanChartsProcessorService } from './processors/CleanChartsProcessorSe
import { CheckExpiredMutingsProcessorService } from './processors/CheckExpiredMutingsProcessorService.js'; import { CheckExpiredMutingsProcessorService } from './processors/CheckExpiredMutingsProcessorService.js';
import { CleanProcessorService } from './processors/CleanProcessorService.js'; import { CleanProcessorService } from './processors/CleanProcessorService.js';
import { AggregateRetentionProcessorService } from './processors/AggregateRetentionProcessorService.js'; import { AggregateRetentionProcessorService } from './processors/AggregateRetentionProcessorService.js';
import { AutoNoteRemovalProcessorService } from './processors/AutoNoteRemovalProcessorService.js';} import { AutoNoteRemovalProcessorService } from './processors/AutoNoteRemovalProcessorService.js';
import { QueueLoggerService } from './QueueLoggerService.js'; import { QueueLoggerService } from './QueueLoggerService.js';
import { QUEUE, baseWorkerOptions } from './const.js'; import { QUEUE, baseWorkerOptions } from './const.js';

1
packages/backend/src/queue/processors/AutoNoteRemovalProcessorService.ts
View file

@ -13,6 +13,7 @@ import { bindThis } from '@/decorators.js';
import { NoteDeleteService } from '@/core/NoteDeleteService.js'; import { NoteDeleteService } from '@/core/NoteDeleteService.js';
import { IdService } from '@/core/IdService.js'; import { IdService } from '@/core/IdService.js';
import { QueueLoggerService } from '../QueueLoggerService.js'; import { QueueLoggerService } from '../QueueLoggerService.js';
import type * as Bull from 'bullmq';
@Injectable() @Injectable()
export class AutoNoteRemovalProcessorService { export class AutoNoteRemovalProcessorService {