Function waitForRunToComplete

references/v3-catalog/src/management.ts:170–182

(runId: string)

}

async function waitForRunToComplete(runId: string) {
  let run = await runs.retrieve(runId);

  while (!run.isCompleted) {
    console.log("run is not completed, waiting...", run);
    await new Promise((resolve) => setTimeout(resolve, 2000));
    run = await runs.retrieve(runId);
  }

  console.log("run is completed", run);

  return run;
}

async function waitForRunToExecute(runId: string) {
  let run = await runs.retrieve(runId);