trigger_and_wait.ts

import { spawnSync, ChildProcessWithoutNullStreams } from "child_process";
import { readFileSync } from 'fs';

import tmp from 'tmp';
tmp.setGracefulCleanup();

function waitFlow(flowname: string,
                  runID: string,
                  resolve: (reason?: any) => void,
                  reject: (value?: any) => void) {

  const cmd = spawnSync('python', [
    flowname + '.py',
    '--quiet',
    'argo-workflows',
    'status',
    runID
  ]);
  if (cmd.error){
    console.log("Status failed: " + cmd.error);
    reject("Status failed: " + cmd.error);
  }else{
    const output = cmd.stderr;
    if (output.includes("Succeeded")){
      console.log(`Run ${runID} succeeded`);
      resolve();
    }else if (output.includes("Failed")){
      console.log(`Run ${runID} failed`);
      reject("run failed");
    }else{
      setTimeout(() => waitFlow(flowname, runID, resolve, reject), 500);
    }
  }
}

async function triggerAndWait(flowname: string) {
  const tmpFile = tmp.fileSync().name;
  const cmd = spawnSync('python', [
      flowname + '.py',
      'argo-workflows',
      'trigger',
      '--run-id-file',
      tmpFile
  ]);
  if (cmd.error){
    console.log("Trigger failed: " + cmd.error);
  }else{
    const runID = readFileSync(tmpFile, { encoding: 'utf-8' });
    console.log(`Triggered run ${runID}`);
    return new Promise((resolve, reject) => {
      waitFlow(flowname, runID, resolve, reject);
    });    
  }
}

triggerAndWait("helloflow");