keith/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey synced 2024-11-30 01:23:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix typo

Browse source
This commit is contained in:
syuilo 2022-02-08 22:18:39 +09:00
parent c9bf8330de
commit d050d5fb18
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
packages/backend/src/queue/index.ts
View file

@ -6,7 +6,7 @@ import { envOption } from '../env';
import processDeliver from './processors/deliver'; import processDeliver from './processors/deliver';
import processInbox from './processors/inbox'; import processInbox from './processors/inbox';
import processDb from './processors/db/index'; import processDb from './processors/db/index';
import procesObjectStorage from './processors/object-storage/index'; import processObjectStorage from './processors/object-storage/index';
import processSystemQueue from './processors/system/index'; import processSystemQueue from './processors/system/index';
import { queueLogger } from './logger'; import { queueLogger } from './logger';
import { DriveFile } from '@/models/entities/drive-file'; import { DriveFile } from '@/models/entities/drive-file';
@ -256,7 +256,7 @@ export default function() {
deliverQueue.process(config.deliverJobConcurrency || 128, processDeliver); deliverQueue.process(config.deliverJobConcurrency || 128, processDeliver);
inboxQueue.process(config.inboxJobConcurrency || 16, processInbox); inboxQueue.process(config.inboxJobConcurrency || 16, processInbox);
processDb(dbQueue); processDb(dbQueue);
procesObjectStorage(objectStorageQueue); processObjectStorage(objectStorageQueue);
systemQueue.add('resyncCharts', { systemQueue.add('resyncCharts', {
}, { }, {