Function processRunExecution

server/src/task-runner.ts:130–582

(data: ExecuteRunData)

};

async function processRunExecution(data: ExecuteRunData): Promise<void> {
  const BROWSER_INIT_TIMEOUT = 60000;
  const BROWSER_PAGE_TIMEOUT = 15000;

  logger.log('info', `Processing run execution job for runId: ${data.runId}, browserId: ${data.browserId}`);

  try {
    const run = await Run.findOne({ where: { runId: data.runId } });
    if (!run) {
      logger.log('error', `Run ${data.runId} not found in database`);
      return;
    }

    if (run.status === 'aborted' || run.status === 'aborting') {
      logger.log('info', `Run ${data.runId} has status ${run.status}, skipping execution`);
      return;
    }

    if (run.status === 'queued') {
      logger.log('info', `Run ${data.runId} has status 'queued', skipping stale execution job`);
      return;
    }

    const plainRun = run.toJSON();

    if ((plainRun.interpreterSettings as any)?.robotType === 'doc-extract') {
      logger.log('info', `Run ${data.runId} is a document robot — skipping browser, running document extraction`);
      const recording = await Robot.findOne({ where: { 'recording_meta.id': plainRun.robotMetaId }, raw: true });
      if (!recording) {
        logger.log('error', `Robot not found for document run ${data.runId}`);
        await run.update({ status: 'failed', finishedAt: new Date().toLocaleString(), log: 'Robot not found' });
        return;
      }
      const { executeDocumentRun } = await import('./utils/document/executeDocumentRun');
      await executeDocumentRun(recording, run, data.userId, serverIo);
      return;
    }

    if ((plainRun.interpreterSettings as any)?.robotType === 'doc-parse') {
      logger.log('info', `Run ${data.runId} is a document-parse robot — skipping browser, running document parsing`);
      const recording = await Robot.findOne({ where: { 'recording_meta.id': plainRun.robotMetaId }, raw: true });
      if (!recording) {
        logger.log('error', `Robot not found for document-parse run ${data.runId}`);
        await run.update({ status: 'failed', finishedAt: new Date().toLocaleString(), log: 'Robot not found' });
        return;
      }
      const { executeDocumentParseRun } = await import('./utils/document/executeDocumentParseRun');
      await executeDocumentParseRun(recording, run, data.userId, serverIo);
      return;
    }

    const browserId = data.browserId || plainRun.browserId;

    if (!browserId) throw new Error(`No browser ID available for run ${data.runId}`);

    logger.log('info', `Looking for browser ${browserId} for run ${data.runId}`);

    let browser = browserPool.getRemoteBrowser(browserId);