Function runJob

src/job.ts:87–119

(
  argv: CliArguments,
  taskData: TaskData,
  { spinner, logger, downloadFile = downloadExportFile, signalEmitter = process }: RunJobDependencies
)

}

export async function runJob(
  argv: CliArguments,
  taskData: TaskData,
  { spinner, logger, downloadFile = downloadExportFile, signalEmitter = process }: RunJobDependencies
): Promise<Job> {
  spinner.text = 'Creating job';

  const cloudconvert = argv.cloudconvert;
  const parameterOptions = await fetchParameterOptions(cloudconvert, taskData);
  const castTaskData = castTaskParameterValues(taskData, parameterOptions);
  const secondaryInputFiles = resolveSecondaryInputFiles(castTaskData, parameterOptions);
  const job = await cloudconvert.jobs.create(buildJobTemplate(castTaskData, argv.files, secondaryInputFiles));
  const cancellation = createJobCancellation(job.id, cloudconvert, spinner, signalEmitter);
  const completion = waitForCompletion(job.id, argv, spinner, logger, downloadFile, cancellation.signal);
  const upload = uploadFiles(
    job,
    createUploadFilesByTaskName(argv.files, secondaryInputFiles),
    argv,
    spinner,
    cancellation.signal
  );

  try {
    await Promise.race([upload, cancellation.promise]);
    spinner.text = 'Processing';

    return await Promise.race([completion, cancellation.promise]);
  } finally {
    cancellation.dispose();
    upload.catch(() => undefined);
    completion.catch(() => undefined);
  }
}

export async function downloadExportFile(
  file: ExportedFile,