Function waitForAllDone

tests/playwright/legacy-ui-install.spec.ts:16–77

(page: import('@playwright/test').Page, timeoutMs = 90_000)

const PACK_CNR_ID = 'comfyui_sigmoidoffsetscheduler';

async function waitForAllDone(page: import('@playwright/test').Page, timeoutMs = 90_000): Promise<void> {
  // Three-phase polling with DETERMINISTIC baseline:
  //   Phase 0 — snapshot baseline. To make the baseline deterministic across
  //             runs (and immune to leaking history from prior tests in the
  //             session), we FETCH the baseline immediately after the caller
  //             has triggered the UI action. The caller is expected to have
  //             called /v2/manager/queue/reset at the start of its test flow
  //             so that done_count starts at 0 for this test's session.
  //   Phase 1 — wait for task acceptance:
  //             total_count > 0 OR is_processing=true OR done_count > baseline
  //   Phase 2 — wait for drain (total_count === 0 && is_processing=false)
  const deadline = Date.now() + timeoutMs;

  // Phase 0: baseline. If fetch fails, treat as 0 but log so the test signal
  // isn't silently degraded.
  let baselineDone = 0;
  const baselineResp = await page.request
    .get('/v2/manager/queue/status')
    .catch(() => null);
  if (baselineResp && baselineResp.ok()) {
    const baseline = await baselineResp.json();
    baselineDone = baseline?.done_count ?? 0;
  } else {
    console.warn('[waitForAllDone] baseline fetch failed — treating as 0');
  }

  // Phase 1: task acceptance
  const acceptDeadline = Math.min(Date.now() + 15_000, deadline);
  let accepted = false;
  while (Date.now() < acceptDeadline) {
    const status = await page.request
      .get('/v2/manager/queue/status')
      .then((r) => r.json())
      .catch(() => null);
    if (
      status &&
      ((status.total_count ?? 0) > 0 ||
        status.is_processing === true ||
        (status.done_count ?? 0) > baselineDone)
    ) {
      accepted = true;
      break;
    }
    await page.waitForTimeout(500);
  }
  if (!accepted) {
    throw new Error('Queue never accepted the task (empty queue for 15s after UI action)');
  }

  // Phase 2: drain
  while (Date.now() < deadline) {
    const status = await page.request
      .get('/v2/manager/queue/status')
      .then((r) => r.json())
      .catch(() => null);
    if (status && status.is_processing === false && (status.total_count ?? 0) === 0) {
      return;
    }