X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=packages%2Fpeertube-runner%2Fserver%2Fserver.ts;fp=packages%2Fpeertube-runner%2Fserver%2Fserver.ts;h=8eff4bd2f4f1600a99c7006d44467ba33c1fb635;hb=5e47f6ab984a7d00782e4c7030afffa1ba480add;hp=e851dfc7cc743521a217c357c101760949dd4394;hpb=6a4905602636afd6650c9e6f4d0fcc2105d91100;p=github%2FChocobozzz%2FPeerTube.git

diff --git a/packages/peertube-runner/server/server.ts b/packages/peertube-runner/server/server.ts
index e851dfc7c..8eff4bd2f 100644
--- a/packages/peertube-runner/server/server.ts
+++ b/packages/peertube-runner/server/server.ts
@@ -8,6 +8,7 @@ import { ConfigManager } from '../shared'
 import { IPCServer } from '../shared/ipc'
 import { logger } from '../shared/logger'
 import { JobWithToken, processJob } from './process'
+import { isJobSupported } from './shared'
 
 type PeerTubeServer = PeerTubeServerCommand & {
   runnerToken: string
@@ -199,12 +200,14 @@ export class RunnerServer {
 
     const { availableJobs } = await server.runnerJobs.request({ runnerToken: server.runnerToken })
 
-    if (availableJobs.length === 0) {
+    const filtered = availableJobs.filter(j => isJobSupported(j))
+
+    if (filtered.length === 0) {
       logger.debug(`No job available on ${server.url} for runner ${server.runnerName}`)
       return undefined
     }
 
-    return availableJobs[0]
+    return filtered[0]
   }
 
   private async tryToExecuteJobAsync (server: PeerTubeServer, jobToAccept: { uuid: string }) {