Function executeRun

server/src/api/record.ts:732–1401

(id: string, userId: string)

};

async function executeRun(id: string, userId: string) {
    let browser: any = null;
    
    try {
        const run = await Run.findOne({ where: { runId: id } });
        if (!run) {
            return {
                success: false,
                error: 'Run not found'
            };
        }

        const plainRun = run.toJSON();

        if (run.status === 'aborted' || run.status === 'aborting') {
            logger.log('info', `API Run ${id} has status ${run.status}, skipping execution`);
            return { success: true };
        }

        if (run.status === 'queued') {
            logger.log('info', `API Run ${id} has status 'queued', skipping stale execution - will be handled by recovery`);
            return { success: true };
        }

        const retryCount = plainRun.retryCount || 0;
        if (retryCount >= 3) {
            logger.log('warn', `API Run ${id} has exceeded max retries (${retryCount}/3), marking as failed`);
            await run.update({
                status: 'failed',
                finishedAt: new Date().toLocaleString(),
                log: `Max retries exceeded (${retryCount}/3) - Run permanently failed`
            });
            return { success: false, error: 'Max retries exceeded' };
        }
        const requestedFormats = run.interpreterSettings.formats;
        const promptInstructionsOverride = run.interpreterSettings.promptInstructions;

        const recording = await Robot.findOne({ where: { 'recording_meta.id': plainRun.robotMetaId }, raw: true });
        if (!recording) {
            return {
                success: false,
                error: 'Recording not found'
            };
        }

        browser = browserPool.getRemoteBrowser(plainRun.browserId);
        if (!browser) {
            throw new Error('Could not access browser');
        }

        let currentPage = await browser.getCurrentPage();
        if (!currentPage) {
            throw new Error('Could not create a new page');
        }

        const robotType = (recording.recording_meta as any)?.type || (recording.recording_meta as any)?.robotType || 'extract';

        if (robotType === 'scrape') {