Function runLocal

bin/cml/runner/launch.js:230–357

(opts)

};

const runLocal = async (opts) => {
  logger.info(`Launching ${cml.driver} runner`);
  const {
    workdir,
    name,
    labels,
    single,
    idleTimeout,
    noRetry,
    cloudSpot,
    dockerVolumes,
    tfResource,
    tpiVersion
  } = opts;

  if (tfResource) {
    await tf.checkMinVersion();

    const tfPath = workdir;
    await fs.mkdir(tfPath, { recursive: true });
    const tfMainPath = join(tfPath, 'main.tf.json');
    const tpl = tf.iterativeProviderTpl({ tpiVersion });
    await fs.writeFile(tfMainPath, JSON.stringify(tpl));

    await tf.init({ dir: tfPath });
    await tf.apply({ dir: tfPath });

    const path = join(tfPath, 'terraform.tfstate');
    const tfstate = await tf.loadTfState({ path });
    tfstate.resources = [
      JSON.parse(Buffer.from(tfResource, 'base64').toString('utf-8'))
    ];
    await tf.saveTfState({ tfstate, path });
  }

  if (process.platform === 'linux') {
    const acpiSock = net.connect('/var/run/acpid.socket');
    acpiSock.on('connect', () => {
      logger.info('Connected to acpid service.');
    });
    acpiSock.on('error', (err) => {
      logger.warn(
        `Error connecting to ACPI socket: ${err.message}. The acpid.service helps with instance termination detection.`
      );
    });
    acpiSock.on('data', (buf) => {
      const data = buf.toString().toLowerCase();
      if (data.includes('power') && data.includes('button')) {
        shutdown({ ...opts, reason: 'ACPI shutdown' });
      }
    });
  }

  const dataHandler =
    ({ cloudSpot }) =>
    async (data) => {
      logger.debug(data.toString());
      const logs = await cml.parseRunnerLog({ data, name, cloudSpot });