qualiteer/lib/jobs/k8s/k8s.js

import cp from "node:child_process";
import { jobBuilder, createFile, deleteFile } from "./k8s-common.js";

const applyFile = async (filePath) => {
  const command = `kubectl apply -f ${filePath}`;
  return new Promise((res, rej) =>
    cp.exec(command, (err, stdout, stderr) => (err && rej(err)) || res(stdout))
  );
};

export default async function createJob(jobRequest) {
  const job = jobBuilder(jobRequest);
  const filePath = createFile(job);
  applyFile(filePath);
  deleteFile(filePath);
}