diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-24 14:45:44 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-24 14:45:44 +0900 |
| commit | dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8 (patch) | |
| tree | 404a262838da93e74e3070c12caa5301554a17bf /packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts | |
| parent | fix type (diff) | |
| download | sharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.tar.gz sharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.tar.bz2 sharkey-dabe5bf7e97adaf9ad6af1854bbacf2c3e7025e8.zip | |
fix type errors
Diffstat (limited to 'packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts')
| -rw-r--r-- | packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts b/packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts index 097e4448a5..3ff3dd090c 100644 --- a/packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts +++ b/packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts @@ -17,14 +17,8 @@ export class ObjectStorageQueueProcessorsService { ) { } - public start(q: Bull.Queue) { - const jobs = { - deleteFile: (job) => this.deleteFileProcessorService.process(job), - cleanRemoteFiles: (job, done) => this.cleanRemoteFilesProcessorService.process(job, done), - } as Record<string, Bull.ProcessCallbackFunction<ObjectStorageJobData | Bull.ProcessPromiseFunction<ObjectStorageJobData>>>; - - for (const [k, v] of Object.entries(jobs)) { - q.process(k, 16, v); - } + public start(q: Bull.Queue): void { + q.process('deleteFile', 16, (job) => this.deleteFileProcessorService.process(job)); + q.process('cleanRemoteFiles', 16, (job, done) => this.cleanRemoteFilesProcessorService.process(job, done)); } } |