INNER CODE UNIT · JavaScript

updateFromNoDatabaseVersion

microsoft/pai · src/database-controller/src/initializer/index.js:12

async function updateFromNoDatabaseVersion(databaseModel) {
  // update from 1.0.0 < version < v1.2.0
  await databaseModel.synchronizeSchema();
  // transfer old frameworks from api server to db
  const frameworks = (await k8s.listFramework()).body.items;
  const upsertPromises = [];
  for (const framework of frameworks) {
    const snapshot = new Snapshot(framework);
    logger.info(`Transferring framework ${snapshot.getName()} to database.`);
    const record = snapshot.getRecordForLegacyTransfer();
    record.requestSynced = true;
    upsertPromises.push(databaseModel.Framework.upsert(record));
  }
  await Promise.all(upsertPromises);
}

// This script should be idempotent.
// If any error happens, it should report the error and exit with a non-zero code.

View source record →