encoder.js

app.processEncodingTasks = function processEncodingTasks() {
  encoderEngine.searchTasks((searchErr, encoderInstructions) => {
    if (!searchErr && encoderInstructions) {
      log.info(`Got encoder instructions, started encoder for task '${encoderInstructions.name}' id:${encoderInstructions._id}`);
      encoderEngine.startEncoder(encoderInstructions, (startErr) => {
        if (!startErr) {
          encoderEngine.setTaskToFinished(encoderInstructions._id, (finishErr) => {
            if (finishErr) {
              log.error(`An error occurred while trying to set the task to finished. ${finishErr.message}`);
            }
            app.startProcessingOnTimeout();
          });
        } else {
          log.error(`An error occurred while starting the encoder. Err: ${startErr}`);
          encoderEngine.setTaskToError(encoderInstructions._id, startErr, (errorErr) => {
            if (errorErr) {
              log.error(`An error occurred while trying to set the task to error. ${errorErr}`);
            }
            app.startProcessingOnTimeout();
          });
        }
      });
    } else if (searchErr) {
      log.info(`An error occurred while searching for encoding tasks. Err: ${searchErr}`);
      app.startProcessingOnTimeout();
    } else {
      log.info('Workflow engine did not return any encoding tasks.');
      app.startProcessingOnTimeout();
    }
  });
};