IntenseWebs/PeerTube
3
0
Fork 0
mirror of https://github.com/Chocobozzz/PeerTube.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests

Browse Source
This commit is contained in:
Chocobozzz 2025-02-12 10:33:34 +01:00
parent 27d14308e5
commit cb5f0b8959
No known key found for this signature in database
GPG Key ID: 583A612D890159BE
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/server-commands/src/server/jobs.ts
View File

@ -7,10 +7,11 @@ async function waitJobs (
serversArg: PeerTubeServer[] | PeerTubeServer, serversArg: PeerTubeServer[] | PeerTubeServer,
options: { options: {
skipDelayed?: boolean // default false skipDelayed?: boolean // default false
skipFailed?: boolean // default false
runnerJobs?: boolean // default false runnerJobs?: boolean // default false
} = {} } = {}
) { ) {
const { skipDelayed = false, runnerJobs = false } = options const { skipDelayed = false, skipFailed = false, runnerJobs = false } = options
const pendingJobWait = process.env.NODE_PENDING_JOB_WAIT const pendingJobWait = process.env.NODE_PENDING_JOB_WAIT
? parseInt(process.env.NODE_PENDING_JOB_WAIT, 10) ? parseInt(process.env.NODE_PENDING_JOB_WAIT, 10)
@ -69,6 +70,8 @@ async function waitJobs (
.then(({ data }) => { .then(({ data }) => {
for (const job of data) { for (const job of data) {
if (job.state.id !== RunnerJobState.COMPLETED) { if (job.state.id !== RunnerJobState.COMPLETED) {
if (skipFailed && job.state.id === RunnerJobState.ERRORED) continue
pendingRequests = true pendingRequests = true
if (process.env.DEBUG) { if (process.env.DEBUG) {

2
packages/tests/src/peertube-runner/video-transcription.ts
View File

@ -109,7 +109,7 @@ describe('Test transcription in peertube-runner program', function () {
this.timeout(360000) this.timeout(360000)
const uuid = await uploadForTranscription(servers[0]) const uuid = await uploadForTranscription(servers[0])
await waitJobs(servers, { runnerJobs: true }) await waitJobs(servers, { runnerJobs: true, skipFailed: true }) // skipFailed because previous test had a failed runner job
await checkAutoCaption({ servers, uuid, objectStorageBaseUrl: objectStorage.getMockCaptionFileBaseUrl() }) await checkAutoCaption({ servers, uuid, objectStorageBaseUrl: objectStorage.getMockCaptionFileBaseUrl() })
await checkLanguage(servers, uuid, 'en') await checkLanguage(servers, uuid, 'en')