diff --git a/packages/tests/src/api/runners/runner-transcription.ts b/packages/tests/src/api/runners/runner-transcription.ts index cbd4b171f..e041f8809 100644 --- a/packages/tests/src/api/runners/runner-transcription.ts +++ b/packages/tests/src/api/runners/runner-transcription.ts @@ -36,6 +36,7 @@ describe('Test runner transcription', function () { async function upload () { const { uuid } = await servers[0].videos.upload({ attributes: { name: 'video', language: undefined } }) + await waitJobs(servers) const { availableJobs } = await servers[0].runnerJobs.request({ runnerToken }) expect(availableJobs).to.have.lengthOf(1) @@ -103,6 +104,23 @@ describe('Test runner transcription', function () { } }) + it('Should error a transcription job and decrease the job count', async function () { + this.timeout(60000) + + const { job, uuid } = await upload() + await servers[0].runnerJobs.error({ runnerToken, jobUUID: job.uuid, jobToken: job.jobToken, message: 'Error' }) + + for (let i = 0; i < 4; i++) { + const { job: { jobToken } } = await servers[0].runnerJobs.accept({ runnerToken, jobUUID: job.uuid }) + + await servers[0].runnerJobs.error({ runnerToken, jobUUID: job.uuid, jobToken, message: 'Error' }) + } + + await waitJobs(servers) + + await servers[0].captions.runGenerate({ videoId: uuid }) + }) + after(async function () { await cleanupTests(servers) }) diff --git a/server/core/lib/runners/job-handlers/transcription-job-handler.ts b/server/core/lib/runners/job-handlers/transcription-job-handler.ts index 077f1afc2..2e830d75c 100644 --- a/server/core/lib/runners/job-handlers/transcription-job-handler.ts +++ b/server/core/lib/runners/job-handlers/transcription-job-handler.ts @@ -75,8 +75,6 @@ export class TranscriptionJobHandler extends AbstractJobHandler