X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fjob-queue%2Fhandlers%2Fvideo-redundancy.ts;h=9cb7a65891b07be7f583ba3a34e6ac56ae3f1dfb;hb=f1569117f9bc468bc38b5b8d32df1bce40cc42ad;hp=319d7090e755581a44325419866cc38c2689bcfd;hpb=d5692d4088cdd9fde3be6ff34be8ce2816dab0cf;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/job-queue/handlers/video-redundancy.ts b/server/lib/job-queue/handlers/video-redundancy.ts index 319d7090e..9cb7a6589 100644 --- a/server/lib/job-queue/handlers/video-redundancy.ts +++ b/server/lib/job-queue/handlers/video-redundancy.ts @@ -1,12 +1,9 @@ -import * as Bull from 'bull' -import { logger } from '../../../helpers/logger' +import { Job } from 'bull' import { VideosRedundancyScheduler } from '@server/lib/schedulers/videos-redundancy-scheduler' +import { VideoRedundancyPayload } from '@shared/models' +import { logger } from '../../../helpers/logger' -export type VideoRedundancyPayload = { - videoId: number -} - -async function processVideoRedundancy (job: Bull.Job) { +async function processVideoRedundancy (job: Job) { const payload = job.data as VideoRedundancyPayload logger.info('Processing video redundancy in job %d.', job.id)