Function buildJobTemplate

src/job.ts:47–85

(
  taskData: TaskData,
  files?: string[],
  secondaryInputFiles: SecondaryInputFiles = {}
)

}

export function buildJobTemplate(
  taskData: TaskData,
  files?: string[],
  secondaryInputFiles: SecondaryInputFiles = {}
): JobTemplate {
  const jobData: JobTemplate = {
    tasks: {
      process: createProcessTaskData(taskData, secondaryInputFiles),
      export: {
        operation: 'export/url',
        input: 'process'
      }
    }
  };

  if (files) {
    jobData.tasks.process.input = [];

    files.forEach((_, index) => {
      const taskName = `upload-${index}`;
      jobData.tasks[taskName] = {
        operation: 'import/upload'
      };
      (jobData.tasks.process.input as string[]).push(taskName);
    });
  }

  for (const [parameterName, parameterFiles] of Object.entries(secondaryInputFiles)) {
    const files = Array.isArray(parameterFiles) ? parameterFiles : [parameterFiles];

    files.forEach((_, index) => {
      jobData.tasks[getSecondaryUploadTaskName(parameterName, index)] = {
        operation: 'import/upload'
      };
    });
  }

  return jobData;
}

export async function runJob(
  argv: CliArguments,