Function pollJob

scripts/studio-host-provider.mjs:194–219

(config, state)

}

async function pollJob(config, state) {
  if (
    state.activeSessions.size + state.inFlightAllocations >=
    config.maxCapacity
  ) {
    return;
  }
  const response = await studioJson(
    config,
    "/api/actions/provider-hosts/jobs/next",
    {
      hostId: config.hostId,
      hostToken: config.hostToken,
    },
  );
  if (!response?.job) {
    return;
  }
  const task = handleJob(config, state, response.job).catch((error) => {
    console.error(
      `[simdeck-provider] job ${response.job.id} failed: ${describeError(error)}`,
    );
  });
  state.activeRequests.add(task);
  task.finally(() => state.activeRequests.delete(task));
}

async function handleJob(config, state, job) {
  if (job.type === "allocate") {