Function buildRuns

src/webui/observer/runs.js:89–109

()

}

function buildRuns() {
  const paths = getObserverPaths();
  const cycle = readJsonSafe(paths.cycleProgressPath, null);
  const solidify = readJsonSafe(paths.solidifyStatePath, null);
  const events = readJsonl(paths.eventsPath).map(redactValue);
  const assetCalls = readJsonl(paths.assetCallLogPath).map(redactValue);
  const pipelineEvents = readPipelineEvents();
  const runs = new Map();

  addCycleRun(runs, cycle, solidify);
  for (const event of events) mergeRun(runs, summaryFromEvent(event));
  for (const call of assetCalls) mergeRun(runs, summaryFromAssetCall(call));
  for (const event of pipelineEvents) mergeRun(runs, summaryFromPipelineEvent(event));

  const now = Date.now();
  return Array.from(runs.values()).map((run) => ({
    ...run,
    status: maybeAbandon(run, now),
    requiresConfirmation: Boolean(run.requiresConfirmation),
  }));
}

function maybeAbandon(run, now) {
  if (run.status !== 'running' || run.finishedAt) return run.status;