From 9cce64a31e66169148dd347727a19d08b14a0367 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Mon, 11 May 2026 22:00:22 +0530
Subject: [PATCH 01/10] fix: screenshot tab focus flickering

---
 src/components/run/InterpretationLog.tsx | 59 +++++++++++-------------
 1 file changed, 27 insertions(+), 32 deletions(-)

diff --git a/src/components/run/InterpretationLog.tsx b/src/components/run/InterpretationLog.tsx
index 79cf40b1..6d6b988e 100644
--- a/src/components/run/InterpretationLog.tsx
+++ b/src/components/run/InterpretationLog.tsx
@@ -2,7 +2,7 @@ import * as React from 'react';
 import SwipeableDrawer from '@mui/material/SwipeableDrawer';
 import Typography from '@mui/material/Typography';
 import { Button, Grid, Box, TextField, IconButton, Tooltip } from '@mui/material';
-import { useCallback, useEffect, useRef, useState } from "react";
+import { useCallback, useEffect, useLayoutEffect, useRef, useState } from "react";
 import { useBrowserDimensionsStore } from "../../context/browserDimensions";
 import Table from '@mui/material/Table';
 import TableBody from '@mui/material/TableBody';
@@ -58,7 +58,7 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
   const previousDataLengths = useRef<Map<number, number>>(new Map());
   const hasAutoFocusedTextTab = useRef<boolean>(false);
   const previousGetText = useRef<boolean>(false);
-  const autoFocusedScreenshotIndices = useRef<Set<number>>(new Set());
+  const autoFocusedScreenshotIds = useRef<Set<number>>(new Set());
 
   const [showPreviewData, setShowPreviewData] = useState<boolean>(false);
   const userClosedDrawer = useRef<boolean>(false);
@@ -78,13 +78,15 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
     )
   , [browserSteps, getText, currentTextActionId]);
 
-  const screenshotData = React.useMemo(() => {
-    const screenshotSteps = browserSteps.filter((step): step is ScreenshotStep =>
-      step.type === 'screenshot'
-    );
+  const screenshotSteps = React.useMemo(() =>
+    browserSteps.filter((step): step is ScreenshotStep =>
+      step.type === 'screenshot' && Boolean(step.screenshotData)
+    )
+  , [browserSteps]);
 
-    return screenshotSteps.filter(step => step.screenshotData).map(step => step.screenshotData!);
-  }, [browserSteps]);
+  const screenshotData = React.useMemo(() =>
+    screenshotSteps.map(step => step.screenshotData!)
+  , [screenshotSteps]);
 
   const toggleDrawer = (newOpen: boolean) => (event: React.KeyboardEvent | React.MouseEvent) => {
     if (
@@ -281,7 +283,6 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
   const handleRemoveScreenshotAction = (screenshotId: number, actionId: string | undefined) => {
     if (!actionId) return;
 
-    const screenshotSteps = browserSteps.filter(step => step.type === 'screenshot' && step.screenshotData);
     const screenshotIndex = screenshotSteps.findIndex(step => step.id === screenshotId);
     const screenshotStep = screenshotSteps[screenshotIndex];
     const screenshotName = screenshotStep?.name || `Screenshot ${screenshotIndex + 1}`;
@@ -343,7 +344,6 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
       setActiveTab(availableTabs.findIndex(tab => tab.id === 'captureText'));
     } else if (hasNewScreenshotData && availableTabs.findIndex(tab => tab.id === 'captureScreenshot') !== -1) {
       setActiveTab(availableTabs.findIndex(tab => tab.id === 'captureScreenshot'));
-      setActiveScreenshotTab(screenshotData.length - 1);
     }
   }, [captureListData.length, captureTextData.length, screenshotData.length]);
 
@@ -351,7 +351,7 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
     browserStepsRef.current = browserSteps;
   }, [browserSteps]);
 
-  useEffect(() => {
+  useLayoutEffect(() => {
     if (captureListData.length > 0 || captureTextData.length > 0 || screenshotData.length > 0) {
       setShowPreviewData(true);
     } else {
@@ -377,7 +377,7 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
       setShowPreviewData(false);
       autoFocusedListIds.current.clear();
       previousDataLengths.current.clear();
-      autoFocusedScreenshotIndices.current.clear();
+      autoFocusedScreenshotIds.current.clear();
       userClosedDrawer.current = false;
       lastListDataLength.current = 0;
       lastTextDataLength.current = 0;
@@ -480,20 +480,6 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
           const screenshotTabIndex = getAvailableTabs().findIndex(tab => tab.id === "captureScreenshot");
           if (screenshotTabIndex !== -1) {
             setActiveTab(screenshotTabIndex);
-            const latestIndex = screenshotData.length - 1;
-            setActiveScreenshotTab(latestIndex);
-
-            if (!autoFocusedScreenshotIndices.current.has(latestIndex)) {
-              autoFocusedScreenshotIndices.current.add(latestIndex);
-              setTimeout(() => {
-                const screenshotSteps = browserSteps.filter(step => step.type === "screenshot");
-                const latestScreenshotStep = screenshotSteps[latestIndex];
-                if (latestScreenshotStep) {
-                  const screenshotName = latestScreenshotStep.name || `Screenshot ${latestIndex + 1}`;
-                  startEdit(latestScreenshotStep.id, 'screenshot', screenshotName);
-                }
-              }, 300);
-            }
           }
         }
       }, 100);
@@ -523,12 +509,22 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
     }
   }, [captureListData.length, isOpen, captureStage]);
 
-  useEffect(() => {
-    if (screenshotData.length > 0 && isOpen) {
-      const latestScreenshotIndex = screenshotData.length - 1;
-      setActiveScreenshotTab(latestScreenshotIndex);
+  useLayoutEffect(() => {
+    if (screenshotSteps.length > 0 && isOpen) {
+      const latestScreenshotIndex = screenshotSteps.length - 1;
+      const latestScreenshot = screenshotSteps[latestScreenshotIndex];
+
+      if (latestScreenshot && !autoFocusedScreenshotIds.current.has(latestScreenshot.id)) {
+        autoFocusedScreenshotIds.current.add(latestScreenshot.id);
+        setActiveScreenshotTab(latestScreenshotIndex);
+        cancelEdit();
+
+        setTimeout(() => {
+          startEdit(latestScreenshot.id, 'screenshot', latestScreenshot.name || `Screenshot ${latestScreenshotIndex + 1}`);
+        }, 300);
+      }
     }
-  }, [screenshotData.length, isOpen]);
+  }, [screenshotSteps.length, isOpen]);
 
   const { darkMode } = useThemeMode();
 
@@ -940,7 +936,6 @@ export const InterpretationLog: React.FC<InterpretationLogProps> = ({ isOpen, se
                       }}
                     >
                       {(() => {
-                        const screenshotSteps = browserSteps.filter(step => step.type === 'screenshot' && step.screenshotData) as Array<{ id: number; name?: string; type: 'screenshot'; fullPage: boolean; actionId?: string; screenshotData?: string }>;
                         return screenshotData.map((screenshot, index) => {
                           const screenshotStep = screenshotSteps[index];
                           if (!screenshotStep) return null;

From c8b1244488d0d79848c4ed45133984039f92e9f1 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 11:26:48 +0530
Subject: [PATCH 02/10] feat: enhance output data ui and format ordering

---
 src/components/run/RunContent.tsx | 689 ++++++++++++++++--------------
 1 file changed, 360 insertions(+), 329 deletions(-)

diff --git a/src/components/run/RunContent.tsx b/src/components/run/RunContent.tsx
index 99af097a..ce722834 100644
--- a/src/components/run/RunContent.tsx
+++ b/src/components/run/RunContent.tsx
@@ -8,6 +8,8 @@ import {
   AccordionSummary,
   AccordionDetails,
   Link,
+  Tooltip,
+  IconButton,
   Tabs,
   Tab
 } from "@mui/material";
@@ -15,7 +17,19 @@ import * as React from "react";
 import { Data } from "./RunsTable";
 import { TabPanel, TabContext } from "@mui/lab";
 import ExpandMoreIcon from '@mui/icons-material/ExpandMore';
-import ArticleIcon from '@mui/icons-material/Article';
+import ImageIcon from '@mui/icons-material/Image';
+import CodeIcon from '@mui/icons-material/Code';
+import DescriptionIcon from '@mui/icons-material/Description';
+import SubjectIcon from '@mui/icons-material/Subject';
+import LinkIcon from '@mui/icons-material/Link';
+import InfoOutlinedIcon from '@mui/icons-material/InfoOutlined';
+import TextFieldsIcon from '@mui/icons-material/TextFields';
+import ViewListIcon from '@mui/icons-material/ViewList';
+import TravelExploreIcon from '@mui/icons-material/TravelExplore';
+import SearchIcon from '@mui/icons-material/Search';
+import PsychologyIcon from '@mui/icons-material/Psychology';
+import StorageIcon from '@mui/icons-material/Storage';
+import { ContentCopy } from "@mui/icons-material";
 import { useEffect, useState } from "react";
 import JSZip from "jszip";
 import Table from '@mui/material/Table';
@@ -195,11 +209,14 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
 
     if (!row.serializableOutput) return;
 
+    const modernKeys = ['scrapeSchema', 'scrapeList', 'crawl', 'search', 'markdown', 'html', 'textContent', 'text', 'links', 'promptResult'];
+    const hasModernData = modernKeys.some(key => row.serializableOutput[key]);
+    const hasLegacyDataInOutput = Object.keys(row.serializableOutput).some(key => !modernKeys.includes(key));
+
     const hasLegacySchema = row.serializableOutput.scrapeSchema && Array.isArray(row.serializableOutput.scrapeSchema);
     const hasLegacyList = row.serializableOutput.scrapeList && Array.isArray(row.serializableOutput.scrapeList);
-    const hasOldFormat = !row.serializableOutput.scrapeSchema && !row.serializableOutput.scrapeList && !row.serializableOutput.crawl && !row.serializableOutput.search && Object.keys(row.serializableOutput).length > 0;
 
-    if (hasLegacySchema || hasLegacyList || hasOldFormat) {
+    if (hasLegacySchema || hasLegacyList || (hasLegacyDataInOutput && !hasModernData)) {
       processLegacyData(row.serializableOutput);
       setIsLegacyData(false);
       return;
@@ -794,6 +811,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
       <Accordion defaultExpanded={defaultExpanded} sx={{ mb: 2 }}>
         <AccordionSummary expandIcon={<ExpandMoreIcon />}>
           <Box sx={{ display: 'flex', alignItems: 'center' }}>
+            <ImageIcon sx={{ mr: 1 }} />
             <Typography variant='h6'>{title}</Typography>
           </Box>
         </AccordionSummary>
@@ -882,77 +900,79 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
     if (!title || title.trim() === '') {
       return (
         <>
-          <Box sx={{ mb: 2 }}>
-            <TableContainer component={Paper} sx={{ maxHeight: 320 }}>
-              <Table stickyHeader aria-label="sticky table">
-                <TableHead>
-                  <TableRow>
-                    {shouldShowAsKeyValue ? (
-                      <>
-                        <TableCell
-                          sx={{
-                            backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
-                          }}
-                        >
-                          Label
-                        </TableCell>
-                        <TableCell
-                          sx={{
-                            backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
-                          }}
-                        >
-                          Value
-                        </TableCell>
-                      </>
-                    ) : (
-                      columns.map((column) => (
-                        <TableCell
-                          key={column}
-                          sx={{
-                            backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
-                          }}
-                        >
-                          {column}
-                        </TableCell>
-                      ))
-                    )}
-                  </TableRow>
-                </TableHead>
-                <TableBody>
+        <Box sx={{ mb: 2 }}>
+          <TableContainer component={Paper} sx={{ maxHeight: 320 }}>
+            <Table stickyHeader aria-label="sticky table">
+              <TableHead>
+                <TableRow>
                   {shouldShowAsKeyValue ? (
-                    columns.map((column) => (
-                      <TableRow key={column}>
-                        <TableCell sx={{ fontWeight: 500 }}>
-                          {column}
-                        </TableCell>
-                        <TableCell>
-                          {data[0][column] === undefined || data[0][column] === ""
-                            ? "-"
-                            : (typeof data[0][column] === 'object'
-                              ? JSON.stringify(data[0][column])
-                              : String(data[0][column]))}
-                        </TableCell>
-                      </TableRow>
-                    ))
+                    <>
+                      <TableCell
+                        sx={{
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa',
+                          minWidth: '100px',
+                          whiteSpace: 'nowrap'
+                        }}
+                      >
+                        Label
+                      </TableCell>
+                      <TableCell
+                        sx={{
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa'
+                        }}
+                      >
+                        Value
+                      </TableCell>
+                    </>
                   ) : (
-                    data.map((row, index) => (
-                      <TableRow key={index}>
-                        {columns.map((column) => (
-                          <TableCell key={column}>
-                            {row[column] === undefined || row[column] === ""
-                              ? "-"
-                              : (typeof row[column] === 'object'
-                                ? JSON.stringify(row[column])
-                                : String(row[column]))}
-                          </TableCell>
-                        ))}
-                      </TableRow>
+                    columns.map((column) => (
+                      <TableCell
+                        key={column}
+                        sx={{
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa'
+                        }}
+                      >
+                        {column}
+                      </TableCell>
                     ))
                   )}
-                </TableBody>
-              </Table>
-            </TableContainer>
-          </Box>
+                </TableRow>
+              </TableHead>
+              <TableBody>
+                {shouldShowAsKeyValue ? (
+                  columns.map((column) => (
+                    <TableRow key={column}>
+                      <TableCell sx={{ fontWeight: 500, whiteSpace: 'nowrap' }}>
+                        {column}
+                      </TableCell>
+                      <TableCell>
+                        {data[0][column] === undefined || data[0][column] === ""
+                          ? "-"
+                          : (typeof data[0][column] === 'object'
+                            ? JSON.stringify(data[0][column])
+                            : String(data[0][column]))}
+                      </TableCell>
+                    </TableRow>
+                  ))
+                ) : (
+                  data.map((row, index) => (
+                    <TableRow key={index}>
+                      {columns.map((column) => (
+                        <TableCell key={column}>
+                          {row[column] === undefined || row[column] === ""
+                            ? "-"
+                            : (typeof row[column] === 'object'
+                              ? JSON.stringify(row[column])
+                              : String(row[column]))}
+                        </TableCell>
+                      ))}
+                    </TableRow>
+                  ))
+                )}
+              </TableBody>
+            </Table>
+          </TableContainer>
+        </Box>
           <Box sx={{ display: 'flex', alignItems: 'center', justifyContent: 'space-between', mb: 2 }}>
             <Box>
               <Button
@@ -997,62 +1017,21 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
       );
     }
 
-    const accordionIdBase = `${title.toLowerCase().replace(/\s+/g, '-')}-${csvFilename.replace(/[^a-zA-Z0-9_-]/g, '-')}`;
-
     return (
       <Accordion defaultExpanded sx={{ mb: 2 }}>
         <AccordionSummary
           expandIcon={<ExpandMoreIcon />}
-          aria-controls={`${accordionIdBase}-content`}
-          id={`${accordionIdBase}-header`}
+          aria-controls={`${title.toLowerCase()}-content`}
+          id={`${title.toLowerCase()}-header`}
         >
           <Box sx={{ display: 'flex', alignItems: 'center' }}>
+            <StorageIcon sx={{ mr: 1 }} />
             <Typography variant='h6'>
               {title}
             </Typography>
           </Box>
         </AccordionSummary>
         <AccordionDetails>
-          <Box sx={{ display: 'flex', alignItems: 'center', justifyContent: 'space-between', mb: 2 }}>
-            <Box>
-              <Button
-                component="a"
-                onClick={() => downloadJSON(data, jsonFilename)}
-                sx={{
-                  color: '#FF00C3',
-                  textTransform: 'none',
-                  mr: 2,
-                  p: 0,
-                  minWidth: 'auto',
-                  backgroundColor: 'transparent',
-                  '&:hover': {
-                    backgroundColor: 'transparent',
-                    textDecoration: 'underline'
-                  }
-                }}
-              >
-                {t('run_content.captured_data.download_json', 'Download JSON')}
-              </Button>
-
-              <Button
-                component="a"
-                onClick={() => downloadCSV(data, columns, csvFilename, isSchemaData, isSchemaTabular)}
-                sx={{
-                  color: '#FF00C3',
-                  textTransform: 'none',
-                  p: 0,
-                  minWidth: 'auto',
-                  backgroundColor: 'transparent',
-                  '&:hover': {
-                    backgroundColor: 'transparent',
-                    textDecoration: 'underline'
-                  }
-                }}
-              >
-                {t('run_content.captured_data.download_csv', 'Download as CSV')}
-              </Button>
-            </Box>
-          </Box>
           <TableContainer component={Paper} sx={{ maxHeight: 320 }}>
             <Table stickyHeader aria-label="sticky table">
               <TableHead>
@@ -1061,14 +1040,16 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                     <>
                       <TableCell
                         sx={{
-                          backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa',
+                          minWidth: '100px',
+                          whiteSpace: 'nowrap'
                         }}
                       >
                         Label
                       </TableCell>
                       <TableCell
                         sx={{
-                          backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa'
                         }}
                       >
                         Value
@@ -1079,7 +1060,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                       <TableCell
                         key={column}
                         sx={{
-                          backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
+                          backgroundColor: darkMode ? '#11111' : '#f8f9fa'
                         }}
                       >
                         {column}
@@ -1092,7 +1073,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 {shouldShowAsKeyValue ? (
                   columns.map((column) => (
                     <TableRow key={column}>
-                      <TableCell sx={{ fontWeight: 500 }}>
+                      <TableCell sx={{ fontWeight: 500, whiteSpace: 'nowrap' }}>
                         {column}
                       </TableCell>
                       <TableCell>
@@ -1122,6 +1103,45 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
               </TableBody>
             </Table>
           </TableContainer>
+
+          <Box sx={{ mt: 2 }}>
+            <Button
+              component="a"
+              onClick={() => downloadJSON(data, jsonFilename)}
+              sx={{
+                color: '#FF00C3',
+                textTransform: 'none',
+                mr: 2,
+                p: 0,
+                minWidth: 'auto',
+                backgroundColor: 'transparent',
+                '&:hover': {
+                  backgroundColor: 'transparent',
+                  textDecoration: 'underline'
+                }
+              }}
+            >
+              {t('run_content.captured_data.download_json', 'Download JSON')}
+            </Button>
+
+            <Button
+              component="a"
+              onClick={() => downloadCSV(data, columns, csvFilename, isSchemaData, isSchemaTabular)}
+              sx={{
+                color: '#FF00C3',
+                textTransform: 'none',
+                p: 0,
+                minWidth: 'auto',
+                backgroundColor: 'transparent',
+                '&:hover': {
+                  backgroundColor: 'transparent',
+                  textDecoration: 'underline'
+                }
+              }}
+            >
+              {t('run_content.captured_data.download_csv', 'Download as CSV')}
+            </Button>
+          </Box>
         </AccordionDetails>
       </Accordion>
     );
@@ -1142,30 +1162,80 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
   return (
     <Box sx={{ width: '100%' }}>
       <TabContext value={tab}>
-        <TabPanel value='output' sx={{ width: '100%', maxWidth: '900px' }}>
-          {hasMarkdown || hasHTML || hasTextFormat || hasLinks ? (
+        <TabPanel value='output' sx={{ width: '100%', maxWidth: '1000px' }}>
+          {row.status === 'running' || row.status === 'queued' ? (
+            <>
+              <Box sx={{ display: 'flex', alignItems: 'center', mb: 2 }}>
+                {workflowProgress ? (
+                  <>
+                    <CircularProgress
+                      size={22}
+                      sx={{ marginRight: '10px' }}
+                    />
+                    {getProgressMessage(workflowProgress.percentage)}
+                  </>
+                ) : (
+                  <>
+                    <CircularProgress size={22} sx={{ marginRight: '10px' }} />
+                    {t('run_content.loading')}
+                  </>
+                )}
+              </Box>
+              <Button color="error" onClick={abortRunHandler} sx={{ mt: 1 }}>
+                {t('run_content.buttons.stop')}
+              </Button>
+            </>
+          ) : (!hasData && !hasScreenshots && !hasMarkdown && !hasHTML && !hasTextFormat && !hasLinks && !hasPromptResult ? (
+            <Box sx={{ p: 2 }}>
+              <Typography paragraph>
+                {t('run_content.no_data_found', 'No data found. Need help?')}{" "}
+                <Link href="mailto:support@maxun.dev" underline="hover" color="#ff00c3">
+                  {t('run_content.contact_support', 'Contact Support')}
+                </Link>{" "}
+                {t('run_content.or', 'or')}{" "}
+                <Link
+                  href="https://github.com/getmaxun/maxun/issues/new"
+                  target="_blank"
+                  rel="noopener"
+                  underline="hover"
+                  color="#ff00c3"
+                >
+                  {t('run_content.open_github_issue', 'Open a GitHub Issue')}
+                </Link>.
+              </Typography>
+            </Box>
+          ) : (
             <Box sx={{ display: 'flex', flexDirection: 'column', gap: 2 }}>
-              {hasMarkdown && (
+              {hasTextFormat && (
                 <Accordion defaultExpanded>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                      <ArticleIcon sx={{ mr: 1 }} />
-                      <Typography variant='h6'>Markdown</Typography>
+                      <SubjectIcon sx={{ mr: 1 }} />
+                      <Typography variant='h6'>Text Content</Typography>
                     </Box>
                   </AccordionSummary>
                   <AccordionDetails>
                     <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
-                      <Box component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '13px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
-                        {markdownContent}
-                      </Box>
+                      <Typography component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '14px', lineHeight: 1.6, m: 0 }}>
+                        {textContent}
+                      </Typography>
                     </Paper>
-
                     <Box sx={{ mt: 2 }}>
-                      <Button
-                        onClick={() => downloadMarkdown(markdownContent, `${row.name || 'content'}.md`)}
+                      <Button 
+                        onClick={() => {
+                          const blob = new Blob([textContent], { type: 'text/plain' });
+                          const url = URL.createObjectURL(blob);
+                          const a = document.createElement('a');
+                          a.href = url;
+                          a.download = `${row.name || 'content'}.txt`;
+                          document.body.appendChild(a);
+                          a.click();
+                          document.body.removeChild(a);
+                          URL.revokeObjectURL(url);
+                        }} 
                         sx={{ color: '#FF00C3', textTransform: 'none', p: 0, minWidth: 'auto', '&:hover': { textDecoration: 'underline', backgroundColor: 'transparent' } }}
                       >
-                        Download Markdown
+                        Download Text
                       </Button>
                     </Box>
                   </AccordionDetails>
@@ -1176,28 +1246,29 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 <Accordion defaultExpanded>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                      <ArticleIcon sx={{ mr: 1 }} />
+                      <CodeIcon sx={{ mr: 1 }} />
                       <Typography variant='h6'>HTML</Typography>
                     </Box>
                   </AccordionSummary>
                   <AccordionDetails>
                     <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
-                      <Box component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '13px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
+                      <Typography component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '14px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
                         {htmlContent}
-                      </Box>
+                      </Typography>
                     </Paper>
-
                     <Box sx={{ mt: 2 }}>
-                      <Button
+                      <Button 
                         onClick={() => {
-                          const blob = new Blob([htmlContent], { type: 'text/html;charset=utf-8;' });
+                          const blob = new Blob([htmlContent], { type: 'text/html' });
                           const url = URL.createObjectURL(blob);
-                          const link = document.createElement("a");
-                          link.href = url;
-                          link.download = `${row.name || 'content'}.html`;
-                          link.click();
-                          setTimeout(() => URL.revokeObjectURL(url), 100);
-                        }}
+                          const a = document.createElement('a');
+                          a.href = url;
+                          a.download = `${row.name || 'content'}.html`;
+                          document.body.appendChild(a);
+                          a.click();
+                          document.body.removeChild(a);
+                          URL.revokeObjectURL(url);
+                        }} 
                         sx={{ color: '#FF00C3', textTransform: 'none', p: 0, minWidth: 'auto', '&:hover': { textDecoration: 'underline', backgroundColor: 'transparent' } }}
                       >
                         Download HTML
@@ -1207,34 +1278,26 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 </Accordion>
               )}
 
-              {hasTextFormat && (
+              {hasMarkdown && (
                 <Accordion defaultExpanded>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                      <ArticleIcon sx={{ mr: 1 }} />
-                      <Typography variant='h6'>Text Content</Typography>
+                      <DescriptionIcon sx={{ mr: 1 }} />
+                      <Typography variant='h6'>Markdown</Typography>
                     </Box>
                   </AccordionSummary>
                   <AccordionDetails>
                     <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
-                      <Box component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '13px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
-                        {textContent}
-                      </Box>
+                      <Typography component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '14px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
+                        {markdownContent}
+                      </Typography>
                     </Paper>
                     <Box sx={{ mt: 2 }}>
-                      <Button
-                        onClick={() => {
-                          const blob = new Blob([textContent], { type: 'text/plain;charset=utf-8;' });
-                          const url = URL.createObjectURL(blob);
-                          const link = document.createElement("a");
-                          link.href = url;
-                          link.download = `${row.name || 'content'}.txt`;
-                          link.click();
-                          setTimeout(() => URL.revokeObjectURL(url), 100);
-                        }}
+                      <Button 
+                        onClick={() => downloadMarkdown(markdownContent, `${row.name || 'content'}.md`)} 
                         sx={{ color: '#FF00C3', textTransform: 'none', p: 0, minWidth: 'auto', '&:hover': { textDecoration: 'underline', backgroundColor: 'transparent' } }}
                       >
-                        Download Text
+                        Download Markdown
                       </Button>
                     </Box>
                   </AccordionDetails>
@@ -1245,7 +1308,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 <Accordion defaultExpanded>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                      <ArticleIcon sx={{ mr: 1 }} />
+                      <LinkIcon sx={{ mr: 1 }} />
                       <Typography variant='h6'>Links ({linksContent.length})</Typography>
                     </Box>
                   </AccordionSummary>
@@ -1282,46 +1345,44 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 </Accordion>
               )}
 
-              {showCapturedScreenshotSection && renderCapturedScreenshotsAccordion(
-                t('run_content.captured_screenshot.title', 'Captured Screenshots'),
-                screenshotKeys.map((label, index) => ({ key: label, label, value: rawScreenshotKeys[index] })).filter(tab => tab.value),
-                currentScreenshotIndex,
-                setCurrentScreenshotIndex,
-                'global-screenshots-primary'
+              {hasPromptResult && promptResultData && (
+                <Accordion defaultExpanded>
+                  <AccordionSummary expandIcon={<ExpandMoreIcon />}>
+                    <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                      <PsychologyIcon sx={{ mr: 1 }} />
+                      <Typography variant='h6'>Smart Queries</Typography>
+                    </Box>
+                  </AccordionSummary>
+                  <AccordionDetails>
+                    <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
+                      <Typography component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '14px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
+                        {promptResultData}
+                      </Typography>
+                    </Paper>
+                    <Box sx={{ mt: 2 }}>
+                      <Button
+                        onClick={() => {
+                          const blob = new Blob([promptResultData], { type: 'text/plain' });
+                          const url = URL.createObjectURL(blob);
+                          const a = document.createElement('a');
+                          a.href = url;
+                          a.download = `${row.name || 'agent'}-result.txt`;
+                          document.body.appendChild(a);
+                          a.click();
+                          document.body.removeChild(a);
+                          URL.revokeObjectURL(url);
+                        }}
+                        sx={{ color: '#FF00C3', textTransform: 'none', p: 0, minWidth: 'auto', '&:hover': { textDecoration: 'underline', backgroundColor: 'transparent' } }}
+                      >
+                        Download Result
+                      </Button>
+                    </Box>
+                  </AccordionDetails>
+                </Accordion>
               )}
-            </Box>
-          ) : (
-            <>
-          {row.status === 'running' || row.status === 'queued' ? (
-            <>
-              <Box sx={{ display: 'flex', alignItems: 'center', mb: 2 }}>
-                {workflowProgress ? (
-                  <>
-                    <CircularProgress 
-                      size={22} 
-                      sx={{ marginRight: '10px' }} 
-                    />
-                    {getProgressMessage(workflowProgress.percentage)}
-                  </>
-                ) : (
-                  <>
-                    <CircularProgress size={22} sx={{ marginRight: '10px' }} />
-                    {t('run_content.loading')}
-                  </>
-                )}
-              </Box>
-              <Button color="error" onClick={abortRunHandler} sx={{ mt: 1 }}>
-                {t('run_content.buttons.stop')}
-              </Button>
-            </>
-          ) : (!hasData && !hasScreenshots && !hasMarkdown && !hasHTML && !hasTextFormat && !hasLinks && !hasPromptResult
-            ? (['failed', 'aborted', 'aborting'].includes(row.status)
-              ? <Typography color='error'>{t('run_content.failed_no_output', 'Run failed before generating output. Check run logs for details.')}</Typography>
-              : <Typography>{t('run_content.empty_output')}</Typography>)
-            : null)}
 
-          {hasData && (
-            <Box sx={{ mb: 3 }}>
+              {(schemaData.length > 0 || listData.length > 0 || legacyData.length > 0) && (
+                <>
               {isLegacyData && (
                 renderDataTable(
                   legacyData,
@@ -1338,6 +1399,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                     <Accordion defaultExpanded sx={{ mb: 2 }}>
                       <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                         <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                          <TextFieldsIcon sx={{ mr: 1 }} />
                           <Typography variant='h6'>
                             {t('run_content.captured_data.schema_title', 'Captured Texts')}
                           </Typography>
@@ -1363,12 +1425,12 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   cursor: 'pointer',
                                   backgroundColor:
                                     currentSchemaIndex === idx
-                                      ? (theme) => theme.palette.mode === 'dark'
+                                      ? darkMode
                                         ? '#121111ff'
                                         : '#e9ecef'
                                       : 'transparent',
                                   borderBottom: currentSchemaIndex === idx ? '3px solid #FF00C3' : 'none',
-                                  color: (theme) => theme.palette.mode === 'dark' ? '#fff' : '#000',
+                                  color: darkMode ? '#fff' : '#000',
                                 }}
                               >
                                 {key}
@@ -1393,6 +1455,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                     <Accordion defaultExpanded sx={{ mb: 2 }}>
                       <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                         <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                          <ViewListIcon sx={{ mr: 1 }} />
                           <Typography variant='h6'>
                             {t('run_content.captured_data.list_title', 'Captured Lists')}
                           </Typography>
@@ -1417,12 +1480,12 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                 cursor: 'pointer',
                                 backgroundColor:
                                   currentListIndex === idx
-                                    ? (theme) => theme.palette.mode === 'dark'
+                                    ? darkMode
                                       ? '#121111ff'
                                       : '#e9ecef'
                                     : 'transparent',
                                 borderBottom: currentListIndex === idx ? '3px solid #FF00C3' : 'none',
-                                color: (theme) => theme.palette.mode === 'dark' ? '#fff' : '#000',
+                                color: darkMode ? '#fff' : '#000',
                               }}
                             >
                               {key}
@@ -1438,7 +1501,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   <TableCell
                                     key={column}
                                     sx={{
-                                      backgroundColor: (theme) => theme.palette.mode === 'dark' ? '#11111' : '#f8f9fa'
+                                      backgroundColor: darkMode ? '#11111' : '#f8f9fa'
                                     }}
                                   >
                                     {column}
@@ -1531,11 +1594,14 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                   )}
                 </>
               )}
+                </>
+              )}
 
               {crawlData.length > 0 && crawlData[0] && crawlData[0].length > 0 && (
                 <Accordion defaultExpanded sx={{ mb: 2 }}>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                      <TravelExploreIcon sx={{ mr: 1 }} />
                       <Typography variant='h6'>
                         Crawl Results
                       </Typography>
@@ -1600,6 +1666,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                         <Accordion defaultExpanded sx={{ mb: 2 }}>
                           <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                             <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                              <InfoOutlinedIcon sx={{ mr: 1 }} />
                               <Typography variant='h6'>
                                 Metadata
                               </Typography>
@@ -1648,7 +1715,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                               <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                 <Typography variant='h6'>
-                                  Text Content
+                                  <SubjectIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Text Content
                                 </Typography>
                               </Box>
                             </AccordionSummary>
@@ -1667,7 +1734,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                     whiteSpace: 'pre-wrap',
                                     wordBreak: 'break-word',
                                     fontFamily: 'monospace',
-                                    fontSize: '0.75rem',
+                                    fontSize: '14px',
+                                    lineHeight: 1.6,
                                     m: 0
                                   }}
                                 >
@@ -1698,7 +1766,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                               <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                 <Typography variant='h6'>
-                                  HTML
+                                  <CodeIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> HTML
                                 </Typography>
                               </Box>
                             </AccordionSummary>
@@ -1717,7 +1785,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                     whiteSpace: 'pre-wrap',
                                     wordBreak: 'break-word',
                                     fontFamily: 'monospace',
-                                    fontSize: '0.65rem',
+                                    fontSize: '14px',
+                                    lineHeight: 1.6,
                                     m: 0
                                   }}
                                 >
@@ -1748,7 +1817,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                               <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                 <Typography variant='h6'>
-                                  Markdown
+                                  <DescriptionIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Markdown
                                 </Typography>
                               </Box>
                             </AccordionSummary>
@@ -1767,7 +1836,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                     whiteSpace: 'pre-wrap',
                                     wordBreak: 'break-word',
                                     fontFamily: 'monospace',
-                                    fontSize: '0.875rem',
+                                    fontSize: '14px',
+                                    lineHeight: 1.6,
                                     m: 0
                                   }}
                                 >
@@ -1793,18 +1863,6 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                           </Accordion>
                         )}
 
-                        {renderCapturedScreenshotsAccordion(
-                          t('run_content.captured_screenshot.title', 'Captured Screenshots'),
-                          [
-                            ...(crawlData[0][currentCrawlIndex].screenshotVisible ? [{ key: 'visible', label: 'Screenshot (Visible)', value: crawlData[0][currentCrawlIndex].screenshotVisible }] : []),
-                            ...(crawlData[0][currentCrawlIndex].screenshotFullpage ? [{ key: 'fullpage', label: 'Screenshot (Full Page)', value: crawlData[0][currentCrawlIndex].screenshotFullpage }] : []),
-                          ],
-                          currentCrawlScreenshotTab,
-                          setCurrentCrawlScreenshotTab,
-                          `crawl-${currentCrawlIndex}`,
-                          false
-                        )}
-
                         {(() => {
                           const validLinks = crawlData[0][currentCrawlIndex].links?.filter((link: any) =>
                             typeof link === 'string' && link.trim() !== ''
@@ -1815,7 +1873,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                               <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                 <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                   <Typography variant='h6'>
-                                    Links ({validLinks.length})
+                                    <LinkIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Links ({validLinks.length})
                                   </Typography>
                                 </Box>
                               </AccordionSummary>
@@ -1848,6 +1906,18 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                           );
                         })()}
 
+                        {renderCapturedScreenshotsAccordion(
+                          t('run_content.captured_screenshot.title', 'Captured Screenshots'),
+                          [
+                            ...(crawlData[0][currentCrawlIndex].screenshotVisible ? [{ key: 'visible', label: 'Screenshot (Visible)', value: crawlData[0][currentCrawlIndex].screenshotVisible }] : []),
+                            ...(crawlData[0][currentCrawlIndex].screenshotFullpage ? [{ key: 'fullpage', label: 'Screenshot (Full Page)', value: crawlData[0][currentCrawlIndex].screenshotFullpage }] : []),
+                          ],
+                          currentCrawlScreenshotTab,
+                          setCurrentCrawlScreenshotTab,
+                          `crawl-${currentCrawlIndex}`,
+                          false
+                        )}
+
                         <Box sx={{ display: 'flex', gap: 2, mt: 2 }}>
                           <Button
                             onClick={() => {
@@ -1893,6 +1963,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 <Accordion defaultExpanded sx={{ mb: 2 }}>
                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                      <SearchIcon sx={{ mr: 1 }} />
                       <Typography variant='h6'>
                         Search Results
                       </Typography>
@@ -1956,6 +2027,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             <Accordion defaultExpanded sx={{ mb: 2 }}>
                               <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                 <Box sx={{ display: 'flex', alignItems: 'center' }}>
+                                  <InfoOutlinedIcon sx={{ mr: 1 }} />
                                   <Typography variant='h6'>
                                     Metadata
                                   </Typography>
@@ -2005,7 +2077,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                 <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                   <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                     <Typography variant='h6'>
-                                      Text Content
+                                      <SubjectIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Text Content
                                     </Typography>
                                   </Box>
                                 </AccordionSummary>
@@ -2024,7 +2096,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                         whiteSpace: 'pre-wrap',
                                         wordBreak: 'break-word',
                                         fontFamily: 'monospace',
-                                        fontSize: '0.75rem',
+                                        fontSize: '14px',
+                                        lineHeight: 1.6,
                                         m: 0
                                       }}
                                     >
@@ -2054,7 +2127,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                 <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                   <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                     <Typography variant='h6'>
-                                      HTML
+                                      <CodeIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> HTML
                                     </Typography>
                                   </Box>
                                 </AccordionSummary>
@@ -2073,7 +2146,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                         whiteSpace: 'pre-wrap',
                                         wordBreak: 'break-word',
                                         fontFamily: 'monospace',
-                                        fontSize: '0.75rem',
+                                        fontSize: '14px',
+                                        lineHeight: 1.6,
                                         m: 0
                                       }}
                                     >
@@ -2105,7 +2179,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                 <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                   <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                     <Typography variant='h6'>
-                                      Markdown
+                                      <DescriptionIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Markdown
                                     </Typography>
                                   </Box>
                                 </AccordionSummary>
@@ -2124,7 +2198,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                         whiteSpace: 'pre-wrap',
                                         wordBreak: 'break-word',
                                         fontFamily: 'monospace',
-                                        fontSize: '0.875rem',
+                                        fontSize: '14px',
+                                        lineHeight: 1.6,
                                         m: 0
                                       }}
                                     >
@@ -2161,7 +2236,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                     <Box sx={{ display: 'flex', alignItems: 'center' }}>
                                       <Typography variant='h6'>
-                                        Links ({validLinks.length})
+                                        <LinkIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Links ({validLinks.length})
                                       </Typography>
                                     </Box>
                                   </AccordionSummary>
@@ -2246,65 +2321,60 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                       </>
                     ) : (
                       <>
-                        <TableContainer component={Paper} sx={{ maxHeight: 600 }}>
-                          <Table stickyHeader aria-label="search-results-table">
+                        <TableContainer component={Paper}>
+                          <Table stickyHeader>
                             <TableHead>
                               <TableRow>
-                                <TableCell
-                                  sx={{
-                                    backgroundColor: darkMode ? '#11111' : '#f8f9fa',
-                                    minWidth: '200px'
-                                  }}
-                                >
-                                  Title
-                                </TableCell>
-                                <TableCell
-                                  sx={{
-                                    backgroundColor: darkMode ? '#11111' : '#f8f9fa',
-                                    minWidth: '250px'
-                                  }}
-                                >
-                                  URL
-                                </TableCell>
-                                <TableCell
-                                  sx={{
-                                    backgroundColor: darkMode ? '#11111' : '#f8f9fa',
-                                    minWidth: '300px'
-                                  }}
-                                >
-                                  Description
-                                </TableCell>
+                                <TableCell sx={{ backgroundColor: darkMode ? '#1e1e1e' : '#f8f9fa', whiteSpace: 'nowrap' }}>Title</TableCell>
+                                <TableCell sx={{ backgroundColor: darkMode ? '#1e1e1e' : '#f8f9fa', whiteSpace: 'nowrap' }}>URL</TableCell>
+                                <TableCell sx={{ backgroundColor: darkMode ? '#1e1e1e' : '#f8f9fa', whiteSpace: 'nowrap' }}>Description</TableCell>
                               </TableRow>
                             </TableHead>
-
                             <TableBody>
-                              {searchData.map((result: any, idx: number) => (
-                                <TableRow key={idx}>
-                                  <TableCell>
-                                    {result.title || '-'}
-                                  </TableCell>
-                                  <TableCell>
-                                    {result.url ? (
-                                      <Link
-                                        href={result.url}
-                                        target="_blank"
-                                        rel="noopener noreferrer"
-                                        sx={{
-                                          color: '#FF00C3',
-                                          textDecoration: 'none',
-                                          '&:hover': {
-                                            textDecoration: 'underline'
-                                          },
-                                          wordBreak: 'break-all'
-                                        }}
-                                      >
-                                        {result.url}
-                                      </Link>
-                                    ) : '-'}
-                                  </TableCell>
-                                  <TableCell>
-                                    {result.description || '-'}
+                              {searchData.map((r: any, i: number) => (
+                                <TableRow key={i}>
+                                  <TableCell sx={{ minWidth: 200 }}>{r.title || '-'}</TableCell>
+                                  <TableCell sx={{ minWidth: 250 }}>
+                                    {r.url && r.url !== '-' ? (
+                                      <Box sx={{ display: 'flex', alignItems: 'center', gap: 1 }}>
+                                        <Tooltip title={r.url}>
+                                          <Link
+                                            href={r.url}
+                                            target="_blank"
+                                            rel="noopener"
+                                            sx={{
+                                              color: '#FF00C3',
+                                              textDecoration: 'none',
+                                              '&:hover': { textDecoration: 'underline' },
+                                              maxWidth: '200px',
+                                              overflow: 'hidden',
+                                              textOverflow: 'ellipsis',
+                                              whiteSpace: 'nowrap',
+                                              display: 'block'
+                                            }}
+                                          >
+                                            {r.url.length > 35 ? r.url.substring(0, 35) + '...' : r.url}
+                                          </Link>
+                                        </Tooltip>
+                                        <IconButton
+                                          size="small"
+                                          onClick={() => {
+                                            navigator.clipboard.writeText(r.url);
+                                          }}
+                                          sx={{
+                                            color: '#6c757d',
+                                            '&:hover': { color: '#FF00C3' },
+                                            p: 0.5
+                                          }}
+                                        >
+                                          <ContentCopy sx={{ fontSize: '0.9rem' }} />
+                                        </IconButton>
+                                      </Box>
+                                    ) : (
+                                      '-'
+                                    )}
                                   </TableCell>
+                                  <TableCell sx={{ minWidth: 300 }}>{r.description || '-'}</TableCell>
                                 </TableRow>
                               ))}
                             </TableBody>
@@ -2334,54 +2404,15 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                   </AccordionDetails>
                 </Accordion>
               )}
+              {showCapturedScreenshotSection && renderCapturedScreenshotsAccordion(
+                t('run_content.captured_screenshot.title', 'Captured Screenshots'),
+                screenshotKeys.map((label, index) => ({ key: label, label, value: rawScreenshotKeys[index] })).filter(tab => tab.value),
+                currentScreenshotIndex,
+                setCurrentScreenshotIndex,
+                'global-screenshots-secondary'
+              )}
             </Box>
-          )}
-
-          {showCapturedScreenshotSection && renderCapturedScreenshotsAccordion(
-            t('run_content.captured_screenshot.title', 'Captured Screenshots'),
-            screenshotKeys.map((label, index) => ({ key: label, label, value: rawScreenshotKeys[index] })).filter(tab => tab.value),
-            currentScreenshotIndex,
-            setCurrentScreenshotIndex,
-            'global-screenshots-secondary'
-          )}
-          </>
-          )}
-
-          {hasPromptResult && promptResultData && (
-            <Accordion defaultExpanded sx={{ mb: 2 }}>
-              <AccordionSummary expandIcon={<ExpandMoreIcon />}>
-                <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                  <ArticleIcon sx={{ mr: 1 }} />
-                  <Typography variant='h6'>Smart Query Result</Typography>
-                </Box>
-              </AccordionSummary>
-              <AccordionDetails>
-                <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
-                  <Box component="pre" sx={{ whiteSpace: 'pre-wrap', wordBreak: 'break-word', fontFamily: 'monospace', fontSize: '13px', lineHeight: 1.6, m: 0, color: 'inherit' }}>
-                    {promptResultData}
-                  </Box>
-                </Paper>
-                <Box sx={{ mt: 2 }}>
-                  <Button
-                    onClick={() => {
-                      const blob = new Blob([promptResultData], { type: 'text/plain' });
-                      const url = URL.createObjectURL(blob);
-                      const a = document.createElement('a');
-                      a.href = url;
-                      a.download = `${row.name || 'smart-query'}-result.txt`;
-                      document.body.appendChild(a);
-                      a.click();
-                      document.body.removeChild(a);
-                      URL.revokeObjectURL(url);
-                    }}
-                    sx={{ color: '#FF00C3', textTransform: 'none', p: 0, minWidth: 'auto', '&:hover': { textDecoration: 'underline', backgroundColor: 'transparent' } }}
-                  >
-                    Download Result
-                  </Button>
-                </Box>
-              </AccordionDetails>
-            </Accordion>
-          )}
+          ))}
         </TabPanel>
       </TabContext>
     </Box>

From 542f886a4defd1ddfa0ca3921fe9076d091d189b Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 12:08:36 +0530
Subject: [PATCH 03/10] fix: naming for screenshot format

---
 src/components/run/RunContent.tsx | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/components/run/RunContent.tsx b/src/components/run/RunContent.tsx
index ce722834..03ce9979 100644
--- a/src/components/run/RunContent.tsx
+++ b/src/components/run/RunContent.tsx
@@ -1158,6 +1158,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
   const hasCrawlPageScreenshots = crawlData.some(group => Array.isArray(group) && group.some((item: any) => item?.screenshotVisible || item?.screenshotFullpage));
   const hasSearchResultScreenshots = searchData.some((item: any) => item?.screenshotVisible || item?.screenshotFullpage);
   const showCapturedScreenshotSection = hasScreenshots && !hasCrawlPageScreenshots && !hasSearchResultScreenshots;
+  const isExtractRobot = schemaData.length > 0 || listData.length > 0 || legacyData.length > 0 || (!hasMarkdown && !hasHTML && !hasTextFormat && !hasLinks && crawlData.length === 0 && searchData.length === 0);
 
   return (
     <Box sx={{ width: '100%' }}>
@@ -1907,7 +1908,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                         })()}
 
                         {renderCapturedScreenshotsAccordion(
-                          t('run_content.captured_screenshot.title', 'Captured Screenshots'),
+                          t('run_content.screenshot.title', 'Screenshots'),
                           [
                             ...(crawlData[0][currentCrawlIndex].screenshotVisible ? [{ key: 'visible', label: 'Screenshot (Visible)', value: crawlData[0][currentCrawlIndex].screenshotVisible }] : []),
                             ...(crawlData[0][currentCrawlIndex].screenshotFullpage ? [{ key: 'fullpage', label: 'Screenshot (Full Page)', value: crawlData[0][currentCrawlIndex].screenshotFullpage }] : []),
@@ -2271,7 +2272,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             })()}
 
                             {renderCapturedScreenshotsAccordion(
-                              t('run_content.captured_screenshot.title', 'Captured Screenshots'),
+                              t('run_content.screenshot.title', 'Screenshots'),
                               [
                                 ...(searchData[currentSearchIndex].screenshotVisible ? [{ key: 'visible', label: 'Screenshot (Visible)', value: searchData[currentSearchIndex].screenshotVisible }] : []),
                                 ...(searchData[currentSearchIndex].screenshotFullpage ? [{ key: 'fullpage', label: 'Screenshot (Full Page)', value: searchData[currentSearchIndex].screenshotFullpage }] : []),
@@ -2405,7 +2406,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                 </Accordion>
               )}
               {showCapturedScreenshotSection && renderCapturedScreenshotsAccordion(
-                t('run_content.captured_screenshot.title', 'Captured Screenshots'),
+                isExtractRobot ? t('run_content.captured_screenshot.title_extract', 'Captured Screenshots') : t('run_content.screenshot.title', 'Screenshots'),
                 screenshotKeys.map((label, index) => ({ key: label, label, value: rawScreenshotKeys[index] })).filter(tab => tab.value),
                 currentScreenshotIndex,
                 setCurrentScreenshotIndex,

From 410075f5cd02f88b8ab452a1ca74b6a8eba4f998 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 12:15:19 +0530
Subject: [PATCH 04/10] fix: align metadata ui

---
 src/components/run/RunContent.tsx | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/components/run/RunContent.tsx b/src/components/run/RunContent.tsx
index 03ce9979..f7b3c9f7 100644
--- a/src/components/run/RunContent.tsx
+++ b/src/components/run/RunContent.tsx
@@ -1667,9 +1667,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                         <Accordion defaultExpanded sx={{ mb: 2 }}>
                           <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                             <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                              <InfoOutlinedIcon sx={{ mr: 1 }} />
                               <Typography variant='h6'>
-                                Metadata
+                                <InfoOutlinedIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Metadata
                               </Typography>
                             </Box>
                           </AccordionSummary>
@@ -2028,9 +2027,8 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                             <Accordion defaultExpanded sx={{ mb: 2 }}>
                               <AccordionSummary expandIcon={<ExpandMoreIcon />}>
                                 <Box sx={{ display: 'flex', alignItems: 'center' }}>
-                                  <InfoOutlinedIcon sx={{ mr: 1 }} />
                                   <Typography variant='h6'>
-                                    Metadata
+                                    <InfoOutlinedIcon sx={{ mr: 1, verticalAlign: 'middle', mb: '3px' }} /> Metadata
                                   </Typography>
                                 </Box>
                               </AccordionSummary>

From 0704651dbbfade72ac9334b8d19f2c0045727b86 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 12:23:20 +0530
Subject: [PATCH 05/10] fix: increase format height

---
 src/components/run/RunContent.tsx | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/components/run/RunContent.tsx b/src/components/run/RunContent.tsx
index f7b3c9f7..584ce5c1 100644
--- a/src/components/run/RunContent.tsx
+++ b/src/components/run/RunContent.tsx
@@ -1314,7 +1314,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                     </Box>
                   </AccordionSummary>
                   <AccordionDetails>
-                    <Paper sx={{ p: 2, maxHeight: 400, overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
+                    <Paper sx={{ p: 2, maxHeight: '500px', overflow: 'auto', backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
                       <Box sx={{ display: 'flex', flexDirection: 'column', gap: 1 }}>
                         {Array.from(new Set(linksContent)).map((link: string, idx: number) => (
                           <Link key={idx} href={link} target="_blank" rel="noopener" sx={{ color: '#FF00C3', wordBreak: 'break-all', fontSize: '0.875rem' }}>
@@ -1723,7 +1723,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                               <Paper
                                 sx={{
                                   p: 2,
-                                  maxHeight: '300px',
+                                  maxHeight: '500px',
                                   overflow: 'auto',
                                   backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                 }}
@@ -1774,7 +1774,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                               <Paper
                                 sx={{
                                   p: 2,
-                                  maxHeight: '300px',
+                                  maxHeight: '500px',
                                   overflow: 'auto',
                                   backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                 }}
@@ -1825,7 +1825,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                               <Paper
                                 sx={{
                                   p: 2,
-                                  maxHeight: '300px',
+                                  maxHeight: '500px',
                                   overflow: 'auto',
                                   backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                 }}
@@ -1878,7 +1878,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                 </Box>
                               </AccordionSummary>
                               <AccordionDetails>
-                                <Paper sx={{ maxHeight: 200, overflow: 'auto', p: 2, backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
+                                <Paper sx={{ maxHeight: '500px', overflow: 'auto', p: 2, backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
                                   <Box sx={{ display: 'flex', flexDirection: 'column', gap: 1 }}>
                                     {(Array.from(new Set(validLinks)) as string[]).map((link: string, idx: number) => (
                                       <Link key={idx} href={link} target="_blank" rel="noopener" sx={{ color: '#FF00C3', wordBreak: 'break-all', fontSize: '0.875rem' }}>
@@ -2084,7 +2084,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   <Paper
                                     sx={{
                                       p: 2,
-                                      maxHeight: '300px',
+                                      maxHeight: '500px',
                                       overflow: 'auto',
                                       backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                     }}
@@ -2134,7 +2134,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   <Paper
                                     sx={{
                                       p: 2,
-                                      maxHeight: '300px',
+                                      maxHeight: '500px',
                                       overflow: 'auto',
                                       backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                     }}
@@ -2186,7 +2186,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                   <Paper
                                     sx={{
                                       p: 2,
-                                      maxHeight: '300px',
+                                      maxHeight: '500px',
                                       overflow: 'auto',
                                       backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5'
                                     }}
@@ -2240,7 +2240,7 @@ export const RunContent = ({ row, currentLog, interpretationInProgress, logEndRe
                                     </Box>
                                   </AccordionSummary>
                                   <AccordionDetails>
-                                    <Paper sx={{ maxHeight: 200, overflow: 'auto', p: 2, backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
+                                    <Paper sx={{ maxHeight: '500px', overflow: 'auto', p: 2, backgroundColor: darkMode ? '#1e1e1e' : '#f5f5f5' }}>
                                       <Box sx={{ display: 'flex', flexDirection: 'column', gap: 1 }}>
                                         {(Array.from(new Set(validLinks)) as string[]).map((link: string, idx: number) => (
                                           <Link key={idx} href={link} target="_blank" rel="noopener" sx={{ color: '#FF00C3', wordBreak: 'break-all', fontSize: '0.875rem' }}>

From 86568608b6812b69de88c12338ffb0e3a514a254 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 13:01:33 +0530
Subject: [PATCH 06/10] feat: add dropdown format icons

---
 src/components/robot/pages/RobotCreate.tsx   | 21 +++++++++++++++++++-
 src/components/robot/pages/RobotEditPage.tsx | 20 +++++++++++++++++++
 2 files changed, 40 insertions(+), 1 deletion(-)

diff --git a/src/components/robot/pages/RobotCreate.tsx b/src/components/robot/pages/RobotCreate.tsx
index 36ce0ef3..856ecd08 100644
--- a/src/components/robot/pages/RobotCreate.tsx
+++ b/src/components/robot/pages/RobotCreate.tsx
@@ -31,7 +31,11 @@ import { canCreateBrowserInState, getActiveBrowserId, stopRecording } from '../.
 import { createScrapeRobot, createLLMRobot, createAndRunRecording, createCrawlRobot, createSearchRobot } from "../../../api/storage";
 import { AuthContext } from '../../../context/auth';
 import { DEFAULT_OUTPUT_FORMATS, OUTPUT_FORMAT_LABELS, OUTPUT_FORMAT_OPTIONS, OutputFormats } from '../../../constants/outputFormats';
-
+import ImageIcon from '@mui/icons-material/Image';
+import CodeIcon from '@mui/icons-material/Code';
+import DescriptionIcon from '@mui/icons-material/Description';
+import SubjectIcon from '@mui/icons-material/Subject';
+import LinkIcon from '@mui/icons-material/Link';
 
 interface TabPanelProps {
   children?: React.ReactNode;
@@ -55,6 +59,18 @@ function TabPanel(props: TabPanelProps) {
   );
 }
 
+const getFormatIcon = (format: string) => {
+  switch (format) {
+    case 'markdown': return <DescriptionIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'html': return <CodeIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'text': return <SubjectIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'links': return <LinkIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'screenshot-visible':
+    case 'screenshot-fullpage': return <ImageIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    default: return null;
+  }
+};
+
 const RobotCreate: React.FC = () => {
   const { t } = useTranslation();
   const navigate = useNavigate();
@@ -760,6 +776,7 @@ const RobotCreate: React.FC = () => {
                       {OUTPUT_FORMAT_OPTIONS.map((format) => (
                         <MenuItem key={format} value={format}>
                           <Checkbox checked={outputFormats.includes(format)} />
+                          {getFormatIcon(format)}
                           {OUTPUT_FORMAT_LABELS[format]}
                         </MenuItem>
                       ))}
@@ -971,6 +988,7 @@ const RobotCreate: React.FC = () => {
                       {OUTPUT_FORMAT_OPTIONS.map((format) => (
                         <MenuItem key={format} value={format}>
                           <Checkbox checked={crawlOutputFormats.includes(format)} />
+                          {getFormatIcon(format)}
                           {OUTPUT_FORMAT_LABELS[format]}
                         </MenuItem>
                       ))}
@@ -1196,6 +1214,7 @@ const RobotCreate: React.FC = () => {
                         {OUTPUT_FORMAT_OPTIONS.map((format) => (
                           <MenuItem key={format} value={format}>
                             <Checkbox checked={searchOutputFormats.includes(format)} />
+                            {getFormatIcon(format)}
                             {OUTPUT_FORMAT_LABELS[format]}
                           </MenuItem>
                         ))}
diff --git a/src/components/robot/pages/RobotEditPage.tsx b/src/components/robot/pages/RobotEditPage.tsx
index a2b76d52..895ea4e1 100644
--- a/src/components/robot/pages/RobotEditPage.tsx
+++ b/src/components/robot/pages/RobotEditPage.tsx
@@ -27,6 +27,11 @@ import {
   OUTPUT_FORMAT_OPTIONS,
   OutputFormats,
 } from "../../../constants/outputFormats";
+import ImageIcon from '@mui/icons-material/Image';
+import CodeIcon from '@mui/icons-material/Code';
+import DescriptionIcon from '@mui/icons-material/Description';
+import SubjectIcon from '@mui/icons-material/Subject';
+import LinkIcon from '@mui/icons-material/Link';
 
 interface RobotMeta {
   name: string;
@@ -128,6 +133,18 @@ interface SearchConfig {
   provider?: string;
 }
 
+const getFormatIcon = (format: string) => {
+  switch (format) {
+    case 'markdown': return <DescriptionIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'html': return <CodeIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'text': return <SubjectIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'links': return <LinkIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    case 'screenshot-visible':
+    case 'screenshot-fullpage': return <ImageIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
+    default: return null;
+  }
+};
+
 export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
   const { t } = useTranslation();
   const navigate = useNavigate();
@@ -849,6 +866,7 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
             {OUTPUT_FORMAT_OPTIONS.map((format) => (
               <MenuItem key={format} value={format}>
                 <Checkbox checked={crawlOutputFormats.includes(format)} />
+                {getFormatIcon(format)}
                 {OUTPUT_FORMAT_LABELS[format]}
               </MenuItem>
             ))}
@@ -1046,6 +1064,7 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
               {OUTPUT_FORMAT_OPTIONS.map((format) => (
                 <MenuItem key={format} value={format}>
                   <Checkbox checked={searchOutputFormats.includes(format)} />
+                  {getFormatIcon(format)}
                   {OUTPUT_FORMAT_LABELS[format]}
                 </MenuItem>
               ))}
@@ -1102,6 +1121,7 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
           {OUTPUT_FORMAT_OPTIONS.map((format) => (
             <MenuItem key={format} value={format}>
               <Checkbox checked={scrapeOutputFormats.includes(format)} />
+              {getFormatIcon(format)}
               {OUTPUT_FORMAT_LABELS[format]}
             </MenuItem>
           ))}

From a185fe64d936e25a44fe7ccabe3ac53a0326e4c2 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 13:09:33 +0530
Subject: [PATCH 07/10] fix: span dropdown format entire width

---
 src/components/robot/pages/RobotCreate.tsx | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/components/robot/pages/RobotCreate.tsx b/src/components/robot/pages/RobotCreate.tsx
index 856ecd08..06f74bb8 100644
--- a/src/components/robot/pages/RobotCreate.tsx
+++ b/src/components/robot/pages/RobotCreate.tsx
@@ -749,7 +749,7 @@ const RobotCreate: React.FC = () => {
                 />
 
                 <Box sx={{ width: '100%', display: 'flex', justifyContent: 'flex-start' }}>
-                  <FormControl sx={{ mb: 2, width: '300px' }}>
+                  <FormControl fullWidth sx={{ mb: 2 }}>
                     <InputLabel id="output-formats-label">Output Formats *</InputLabel>
                     <Select
                       labelId="output-formats-label"
@@ -969,7 +969,7 @@ const RobotCreate: React.FC = () => {
                 />
 
                 <Box sx={{ width: '100%', display: 'flex', justifyContent: 'flex-start', mb: 2 }}>
-                  <FormControl sx={{ width: '300px' }}>
+                  <FormControl fullWidth sx={{ mb: 2 }}>
                     <InputLabel id="crawl-output-formats-label">Output Formats *</InputLabel>
                     <Select
                       labelId="crawl-output-formats-label"
@@ -1195,7 +1195,7 @@ const RobotCreate: React.FC = () => {
 
                 {searchMode === 'scrape' ? (
                   <Box sx={{ width: '100%', display: 'flex', justifyContent: 'flex-start', mb: 2 }}>
-                    <FormControl sx={{ width: '300px' }}>
+                    <FormControl fullWidth sx={{ mb: 2 }}>
                       <InputLabel id="search-output-formats-label">Output Formats *</InputLabel>
                       <Select
                         labelId="search-output-formats-label"

From 157c6fbb3fae87468fd373bdae26e2f4bc2ed771 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Tue, 12 May 2026 21:13:05 +0530
Subject: [PATCH 08/10] fix: rm dropdown icon formats

---
 src/components/robot/pages/RobotCreate.tsx   | 20 --------------------
 src/components/robot/pages/RobotEditPage.tsx | 20 --------------------
 2 files changed, 40 deletions(-)

diff --git a/src/components/robot/pages/RobotCreate.tsx b/src/components/robot/pages/RobotCreate.tsx
index 06f74bb8..a70b224f 100644
--- a/src/components/robot/pages/RobotCreate.tsx
+++ b/src/components/robot/pages/RobotCreate.tsx
@@ -31,11 +31,6 @@ import { canCreateBrowserInState, getActiveBrowserId, stopRecording } from '../.
 import { createScrapeRobot, createLLMRobot, createAndRunRecording, createCrawlRobot, createSearchRobot } from "../../../api/storage";
 import { AuthContext } from '../../../context/auth';
 import { DEFAULT_OUTPUT_FORMATS, OUTPUT_FORMAT_LABELS, OUTPUT_FORMAT_OPTIONS, OutputFormats } from '../../../constants/outputFormats';
-import ImageIcon from '@mui/icons-material/Image';
-import CodeIcon from '@mui/icons-material/Code';
-import DescriptionIcon from '@mui/icons-material/Description';
-import SubjectIcon from '@mui/icons-material/Subject';
-import LinkIcon from '@mui/icons-material/Link';
 
 interface TabPanelProps {
   children?: React.ReactNode;
@@ -59,18 +54,6 @@ function TabPanel(props: TabPanelProps) {
   );
 }
 
-const getFormatIcon = (format: string) => {
-  switch (format) {
-    case 'markdown': return <DescriptionIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'html': return <CodeIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'text': return <SubjectIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'links': return <LinkIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'screenshot-visible':
-    case 'screenshot-fullpage': return <ImageIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    default: return null;
-  }
-};
-
 const RobotCreate: React.FC = () => {
   const { t } = useTranslation();
   const navigate = useNavigate();
@@ -776,7 +759,6 @@ const RobotCreate: React.FC = () => {
                       {OUTPUT_FORMAT_OPTIONS.map((format) => (
                         <MenuItem key={format} value={format}>
                           <Checkbox checked={outputFormats.includes(format)} />
-                          {getFormatIcon(format)}
                           {OUTPUT_FORMAT_LABELS[format]}
                         </MenuItem>
                       ))}
@@ -988,7 +970,6 @@ const RobotCreate: React.FC = () => {
                       {OUTPUT_FORMAT_OPTIONS.map((format) => (
                         <MenuItem key={format} value={format}>
                           <Checkbox checked={crawlOutputFormats.includes(format)} />
-                          {getFormatIcon(format)}
                           {OUTPUT_FORMAT_LABELS[format]}
                         </MenuItem>
                       ))}
@@ -1214,7 +1195,6 @@ const RobotCreate: React.FC = () => {
                         {OUTPUT_FORMAT_OPTIONS.map((format) => (
                           <MenuItem key={format} value={format}>
                             <Checkbox checked={searchOutputFormats.includes(format)} />
-                            {getFormatIcon(format)}
                             {OUTPUT_FORMAT_LABELS[format]}
                           </MenuItem>
                         ))}
diff --git a/src/components/robot/pages/RobotEditPage.tsx b/src/components/robot/pages/RobotEditPage.tsx
index 895ea4e1..a2b76d52 100644
--- a/src/components/robot/pages/RobotEditPage.tsx
+++ b/src/components/robot/pages/RobotEditPage.tsx
@@ -27,11 +27,6 @@ import {
   OUTPUT_FORMAT_OPTIONS,
   OutputFormats,
 } from "../../../constants/outputFormats";
-import ImageIcon from '@mui/icons-material/Image';
-import CodeIcon from '@mui/icons-material/Code';
-import DescriptionIcon from '@mui/icons-material/Description';
-import SubjectIcon from '@mui/icons-material/Subject';
-import LinkIcon from '@mui/icons-material/Link';
 
 interface RobotMeta {
   name: string;
@@ -133,18 +128,6 @@ interface SearchConfig {
   provider?: string;
 }
 
-const getFormatIcon = (format: string) => {
-  switch (format) {
-    case 'markdown': return <DescriptionIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'html': return <CodeIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'text': return <SubjectIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'links': return <LinkIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    case 'screenshot-visible':
-    case 'screenshot-fullpage': return <ImageIcon sx={{ mr: 1, fontSize: 20, verticalAlign: 'middle' }} />;
-    default: return null;
-  }
-};
-
 export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
   const { t } = useTranslation();
   const navigate = useNavigate();
@@ -866,7 +849,6 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
             {OUTPUT_FORMAT_OPTIONS.map((format) => (
               <MenuItem key={format} value={format}>
                 <Checkbox checked={crawlOutputFormats.includes(format)} />
-                {getFormatIcon(format)}
                 {OUTPUT_FORMAT_LABELS[format]}
               </MenuItem>
             ))}
@@ -1064,7 +1046,6 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
               {OUTPUT_FORMAT_OPTIONS.map((format) => (
                 <MenuItem key={format} value={format}>
                   <Checkbox checked={searchOutputFormats.includes(format)} />
-                  {getFormatIcon(format)}
                   {OUTPUT_FORMAT_LABELS[format]}
                 </MenuItem>
               ))}
@@ -1121,7 +1102,6 @@ export const RobotEditPage = ({ handleStart }: RobotSettingsProps) => {
           {OUTPUT_FORMAT_OPTIONS.map((format) => (
             <MenuItem key={format} value={format}>
               <Checkbox checked={scrapeOutputFormats.includes(format)} />
-              {getFormatIcon(format)}
               {OUTPUT_FORMAT_LABELS[format]}
             </MenuItem>
           ))}

From a76aa1031ec7d81055fea099f91a111e7d5db232 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Wed, 13 May 2026 16:08:05 +0530
Subject: [PATCH 09/10] chore: move pgboss files to legacy

---
 {server/src => legacy/server}/pgboss-worker.ts  | 0
 {server/src/storage => legacy/server}/pgboss.ts | 0
 2 files changed, 0 insertions(+), 0 deletions(-)
 rename {server/src => legacy/server}/pgboss-worker.ts (100%)
 rename {server/src/storage => legacy/server}/pgboss.ts (100%)

diff --git a/server/src/pgboss-worker.ts b/legacy/server/pgboss-worker.ts
similarity index 100%
rename from server/src/pgboss-worker.ts
rename to legacy/server/pgboss-worker.ts
diff --git a/server/src/storage/pgboss.ts b/legacy/server/pgboss.ts
similarity index 100%
rename from server/src/storage/pgboss.ts
rename to legacy/server/pgboss.ts

From e9d58fd5ab48e1865d2d8d65d55a7c0cbd10bb89 Mon Sep 17 00:00:00 2001
From: Rohit Rajan <rohit.rajan031101@gmail.com>
Date: Wed, 13 May 2026 16:09:53 +0530
Subject: [PATCH 10/10] feat: port from pgboss to graphile worker

---
 package.json                         |   2 +-
 server/src/models/Robot.ts           |   1 +
 server/src/routes/record.ts          | 172 +------
 server/src/routes/storage.ts         |  45 +-
 server/src/schedule-worker.ts        | 273 ++++++-----
 server/src/server.ts                 |  90 +---
 server/src/storage/graphileWorker.ts |  79 ++++
 server/src/storage/schedule.ts       |  78 ++--
 server/src/task-runner.ts            | 672 +++++++++++++++++++++++++++
 9 files changed, 981 insertions(+), 431 deletions(-)
 create mode 100644 server/src/storage/graphileWorker.ts
 create mode 100644 server/src/task-runner.ts

diff --git a/package.json b/package.json
index 71eb0747..e937de9a 100644
--- a/package.json
+++ b/package.json
@@ -41,6 +41,7 @@
     "fortawesome": "^0.0.1-security",
     "google-auth-library": "^9.14.1",
     "googleapis": "^144.0.0",
+    "graphile-worker": "^0.16.6",
     "i18next": "^24.0.2",
     "i18next-browser-languagedetector": "^8.0.0",
     "i18next-http-backend": "^3.0.1",
@@ -58,7 +59,6 @@
     "moment-timezone": "^0.5.45",
     "node-cron": "^3.0.3",
     "pg": "^8.13.0",
-    "pg-boss": "^10.1.6",
     "pkce-challenge": "^4.1.0",
     "playwright-core": "1.57.0",
     "posthog-node": "^4.2.1",
diff --git a/server/src/models/Robot.ts b/server/src/models/Robot.ts
index ebd00b11..d98277cb 100644
--- a/server/src/models/Robot.ts
+++ b/server/src/models/Robot.ts
@@ -69,6 +69,7 @@ interface ScheduleConfig {
   nextRunAt?: Date;
   dayOfMonth?: string;
   cronExpression?: string;
+  schedulerClaimedAt?: Date;
 }
 
 interface RobotCreationAttributes extends Optional<RobotAttributes, 'id'> { }
diff --git a/server/src/routes/record.ts b/server/src/routes/record.ts
index ad7684fe..ff7db5e3 100644
--- a/server/src/routes/record.ts
+++ b/server/src/routes/record.ts
@@ -16,7 +16,6 @@ import {
 } from '../browser-management/controller';
 import logger from "../logger";
 import { requireSignIn } from '../middlewares/auth';
-import { pgBossClient } from '../storage/pgboss';
 
 export const router = Router();
 
@@ -24,102 +23,36 @@ export interface AuthenticatedRequest extends Request {
     user?: any;
 }
 
-async function waitForJobCompletion(jobId: string, queueName: string, timeout = 15000): Promise<any> {
-    return new Promise((resolve, reject) => {
-      const startTime = Date.now();
-      
-      const checkJobStatus = async () => {
-        if (Date.now() - startTime > timeout) {
-          return reject(new Error(`Timeout waiting for job ${jobId} to complete`));
-        }
-        
-        try {
-          const job = await pgBossClient.getJobById(queueName, jobId);
-          
-          if (!job) {
-            return reject(new Error(`Job ${jobId} not found`));
-          }
-          
-          if (job.state === 'completed') {
-            return resolve(job.output);
-          }
-          
-          if (job.state === 'failed') {
-            return reject(new Error(`Job ${jobId} failed.`));
-          }
-          
-          setTimeout(checkJobStatus, 200);
-        } catch (error) {
-          reject(error);
-        }
-      };
-      
-      checkJobStatus();
-    });
-}
-
 /**
  * Logs information about remote browser recording session.
  */
 router.all('/', requireSignIn, (req, res, next) => {
     logger.log('debug', `The record API was invoked: ${req.url}`)
-    next() // pass control to the next handler
+    next()
 })
 
-
 /**
  * GET endpoint for starting the remote browser recording session
- * Waits for job completion
  */
 router.get('/start', requireSignIn, async (req: AuthenticatedRequest, res: Response) => {
     if (!req.user) {
         return res.status(401).send('User not authenticated');
     }
-    
+
     try {
-        await pgBossClient.createQueue('initialize-browser-recording');
-        
-        const jobId = await pgBossClient.send('initialize-browser-recording', {
-            userId: req.user.id,
-            timestamp: new Date().toISOString()
-        });
-        
-        if (!jobId) {
-            const browserId = initializeRemoteBrowserForRecording(req.user.id);
-            return res.send(browserId);
-        }
-        
-        logger.log('info', `Queued browser initialization job: ${jobId}, waiting for completion...`);
-        
-        try {
-            const result = await waitForJobCompletion(jobId, 'initialize-browser-recording', 15000);
-            
-            if (result && result.browserId) {
-                return res.send(result.browserId);
-            } else {
-                return res.send(jobId);
-            }
-        } catch (waitError: any) {
-            return res.send(jobId);
-        }
+        const browserId = initializeRemoteBrowserForRecording(req.user.id);
+        return res.send(browserId);
     } catch (error: any) {
-        logger.log('error', `Failed to queue browser initialization job: ${error.message}`);
-        
-        try {
-            const browserId = initializeRemoteBrowserForRecording(req.user.id);
-            return res.send( browserId );
-        } catch (directError: any) {
-            logger.log('error', `Direct initialization also failed: ${directError.message}`);
-            return res.status(500).send('Failed to start recording');
-        }
+        logger.log('error', `Failed to start browser recording: ${error.message}`);
+        return res.status(500).send('Failed to start recording');
     }
 });
 
 /**
- * POST endpoint for starting the remote browser recording session accepting browser launch options.
+ * POST endpoint for starting the remote browser recording session.
  * returns session's id
  */
-router.post('/start', requireSignIn, (req: AuthenticatedRequest, res:Response) => {
+router.post('/start', requireSignIn, (req: AuthenticatedRequest, res: Response) => {
     if (!req.user) {
         return res.status(401).send('User not authenticated');
     }
@@ -129,44 +62,17 @@ router.post('/start', requireSignIn, (req: AuthenticatedRequest, res:Response) =
 
 /**
  * GET endpoint for terminating the remote browser recording session.
- * returns whether the termination was successful
  */
 router.get('/stop/:browserId', requireSignIn, async (req: AuthenticatedRequest, res) => {
     if (!req.user) {
         return res.status(401).send('User not authenticated');
     }
 
-    // Cancel the recording timeout synchronously before any async work
-    // to prevent the timer firing during the pgBoss job queue window.
     clearRecordingTimeout(req.params.browserId);
 
     try {
-        await pgBossClient.createQueue('destroy-browser');
-        
-        const jobId = await pgBossClient.send('destroy-browser', {
-            browserId: req.params.browserId,
-            userId: req.user.id,
-            timestamp: new Date().toISOString()
-        });
-
-        if (!jobId) {
-            await destroyRemoteBrowser(req.params.browserId, req.user.id);
-            return res.send(false);
-        }
-
-        logger.log('info', `Queued browser destruction job: ${jobId}, waiting for completion...`);
-
-        try {
-            const result = await waitForJobCompletion(jobId, 'destroy-browser', 15000);
-            
-            if (result) {
-                return res.send(result.success);
-            } else {
-                return res.send(false);
-            }
-        } catch (waitError: any) {
-            return res.send(false);
-        }
+        const success = await destroyRemoteBrowser(req.params.browserId, req.user.id);
+        return res.send(success);
     } catch (error: any) {
         logger.log('error', `Failed to stop browser: ${error.message}`);
         return res.status(500).send(false);
@@ -235,33 +141,10 @@ router.get('/interpret', requireSignIn, async (req: AuthenticatedRequest, res) =
     }
 
     try {
-        await pgBossClient.createQueue('interpret-workflow');
-        
-        const jobId = await pgBossClient.send('interpret-workflow', {
-            userId: req.user.id,
-            timestamp: new Date().toISOString()
-        });
-
-        if (!jobId) {
-            await interpretWholeWorkflow(req.user?.id);
-            return res.send('interpretation done');
-        }
-
-        logger.log('info', `Queued interpret workflow job: ${jobId}, waiting for completion...`);
-
-        try {
-            const result = await waitForJobCompletion(jobId, 'interpret-workflow', 1000000);
-            
-            if (result) {
-                return res.send('interpretation done');
-            } else {
-                return res.send('interpretation failed');
-            }
-        } catch (waitError: any) {
-            return res.send('interpretation failed');
-        }
+        await interpretWholeWorkflow(req.user?.id);
+        return res.send('interpretation done');
     } catch (error: any) {
-        logger.log('error', `Failed to stop interpret workflow: ${error.message}`);
+        logger.log('error', `Failed to interpret workflow: ${error.message}`);
         return res.status(500).send('interpretation failed');
     }
 });
@@ -272,35 +155,12 @@ router.get('/interpret/stop', requireSignIn, async (req: AuthenticatedRequest, r
     }
 
     try {
-        await pgBossClient.createQueue('stop-interpretation');
-        
-        const jobId = await pgBossClient.send('stop-interpretation', {
-            userId: req.user.id,
-            timestamp: new Date().toISOString()
-        });
-
-        if (!jobId) {
-            await stopRunningInterpretation(req.user?.id);
-            return res.send('interpretation stopped');
-        }
-
-        logger.log('info', `Queued stop interpret workflow job: ${jobId}, waiting for completion...`);
-
-        try {
-            const result = await waitForJobCompletion(jobId, 'stop-interpretation', 15000);
-            
-            if (result) {
-                return res.send('interpretation stopped');
-            } else {
-                return res.send('interpretation failed to stop');
-            }
-        } catch (waitError: any) {
-            return res.send('interpretation failed to stop');
-        }
+        await stopRunningInterpretation(req.user?.id);
+        return res.send('interpretation stopped');
     } catch (error: any) {
         logger.log('error', `Failed to stop interpretation: ${error.message}`);
         return res.status(500).send('interpretation failed to stop');
     }
 });
 
-export default router;
\ No newline at end of file
+export default router;
diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts
index 318a835a..569f8064 100644
--- a/server/src/routes/storage.ts
+++ b/server/src/routes/storage.ts
@@ -14,7 +14,8 @@ import { capture } from "../utils/analytics";
 import { encrypt, decrypt } from '../utils/auth';
 import { WorkflowFile } from 'maxun-core';
 import { cancelScheduledWorkflow, scheduleWorkflow } from '../storage/schedule';
-import { pgBossClient } from '../storage/pgboss';
+import { addJob } from '../storage/graphileWorker';
+import { QUEUE_NAMES } from '../task-runner';
 import { WorkflowEnricher } from '../sdk/workflowEnricher';
 import sequelizeInstance from '../storage/db';
 import { Op } from 'sequelize';
@@ -937,7 +938,7 @@ router.delete('/runs/:id', requireSignIn, async (req: AuthenticatedRequest, res)
  * PUT endpoint for starting a remote browser instance and saving run metadata to the storage.
  * Making it ready for interpretation and returning a runId.
  * 
- * If the user has reached their browser limit, the run will be queued using pgBossClient.
+ * If the user has reached their browser limit, the run will be queued.
  */
 router.put('/runs/:id', requireSignIn, async (req: AuthenticatedRequest, res) => {
   try {
@@ -1010,15 +1011,12 @@ router.put('/runs/:id', requireSignIn, async (req: AuthenticatedRequest, res) =>
       }
 
       try {
-        const userQueueName = `execute-run-user-${req.user.id}`;
-        await pgBossClient.createQueue(userQueueName);
-       
-        const jobId = await pgBossClient.send(userQueueName, {
+        const jobId = await addJob(QUEUE_NAMES.EXECUTE_RUN, {
           userId: req.user.id,
           runId: runId,
-          browserId: browserId, 
-        });
-        
+          browserId: browserId,
+        }, { maxAttempts: 1 });
+
         logger.log('info', `Queued run execution job with ID: ${jobId} for run: ${runId}`);
       } catch (queueError: any) {
         logger.log('error', `Failed to queue run execution: ${queueError.message}`);
@@ -1125,16 +1123,11 @@ router.post('/runs/run/:id', requireSignIn, async (req: AuthenticatedRequest, re
     }
 
     try {
-      const userQueueName = `execute-run-user-${req.user.id}`;
-
-      // Queue the execution job
-      await pgBossClient.createQueue(userQueueName);
-
-      const jobId = await pgBossClient.send(userQueueName, {
+      const jobId = await addJob(QUEUE_NAMES.EXECUTE_RUN, {
         userId: req.user.id,
         runId: req.params.id,
-        browserId: plainRun.browserId
-      });
+        browserId: plainRun.browserId,
+      }, { maxAttempts: 1 });
 
       logger.log('info', `Queued run execution job with ID: ${jobId} for run: ${req.params.id}`);
     } catch (queueError: any) {
@@ -1320,7 +1313,7 @@ router.delete('/schedule/:id', requireSignIn, async (req: AuthenticatedRequest,
       return res.status(404).json({ error: 'Robot not found' });
     }
 
-    // Cancel the scheduled job in pgBossClient
+    // Cancel the scheduled job
     try {
       await cancelScheduledWorkflow(id);
     } catch (error) {
@@ -1400,13 +1393,10 @@ router.post('/runs/abort/:id', requireSignIn, async (req: AuthenticatedRequest,
       logger.log('warn', `Failed to immediately stop interpreter: ${immediateStopError.message}`);
     }
 
-    const userQueueName = `abort-run-user-${req.user.id}`;
-    await pgBossClient.createQueue(userQueueName);
-  
-    const jobId = await pgBossClient.send(userQueueName, {
+    const jobId = await addJob(QUEUE_NAMES.ABORT_RUN, {
       userId: req.user.id,
-      runId: req.params.id
-    });
+      runId: req.params.id,
+    }, { maxAttempts: 3 });
 
     logger.log('info', `Abort signal sent for run ${req.params.id}, job ID: ${jobId}`);
 
@@ -1476,14 +1466,11 @@ async function processQueuedRuns() {
           log: 'Browser created and ready for execution'
         });
 
-        const userQueueName = `execute-run-user-${userId}`;
-        await pgBossClient.createQueue(userQueueName);
-        
-        const jobId = await pgBossClient.send(userQueueName, {
+        const jobId = await addJob(QUEUE_NAMES.EXECUTE_RUN, {
           userId: userId,
           runId: queuedRun.runId,
           browserId: newBrowserId,
-        });
+        }, { maxAttempts: 1 });
 
         logger.log('info', `Queued execution for run ${queuedRun.runId} with ready browser ${newBrowserId}, job ID: ${jobId}`);
         
diff --git a/server/src/schedule-worker.ts b/server/src/schedule-worker.ts
index 1759590d..0312ab09 100644
--- a/server/src/schedule-worker.ts
+++ b/server/src/schedule-worker.ts
@@ -1,154 +1,189 @@
 /**
- * Worker process focused solely on scheduling logic
+ * DB-backed schedule worker.
+ * Polls the robot table for due scheduled robots and enqueues them
+ * via Graphile Worker. No pgboss dependency.
  */
-import PgBoss, { Job } from 'pg-boss';
+import { Op, QueryTypes, Sequelize } from 'sequelize';
 import logger from './logger';
 import Robot from './models/Robot';
-import { handleRunRecording } from './workflow-management/scheduler';
+import sequelize from './storage/db';
 import { computeNextRun } from './utils/schedule';
+import { addJob } from './storage/graphileWorker';
+import { QUEUE_NAMES } from './task-runner';
 
-if (!process.env.DB_USER || !process.env.DB_PASSWORD || !process.env.DB_HOST || !process.env.DB_PORT || !process.env.DB_NAME) {
-    throw new Error('One or more required environment variables are missing.');
-}
+const DB_SCHEDULER_BATCH_SIZE = 10;
+const DB_SCHEDULER_POLL_MS = 30000;
+const DB_SCHEDULER_CLAIM_TIMEOUT_MS = 10 * 60 * 1000;
+const DB_SCHEDULER_ADVISORY_LOCK_KEY = 43821742;
 
-const pgBossConnectionString = `postgresql://${process.env.DB_USER}:${encodeURIComponent(process.env.DB_PASSWORD)}@${process.env.DB_HOST}:${process.env.DB_PORT}/${process.env.DB_NAME}`;
+let scheduleWorkerStarted = false;
+let dbScheduleTickRunning = false;
+const workerIntervals: NodeJS.Timeout[] = [];
 
-export const pgBoss = new PgBoss({
-  connectionString: pgBossConnectionString,
-  max: 3,
-  expireInHours: 23,
-  ...(process.env.DB_SSL === 'true' && { ssl: true }),
-});
-
-const registeredQueues = new Set<string>();
-
-interface ScheduledWorkflowData {
+interface DbScheduledRobot {
   id: string;
-  runId: string;
+  robotMetaId: string;
   userId: string;
 }
-/**
- * Process a scheduled workflow job
- */
-async function processScheduledWorkflow(job: Job<ScheduledWorkflowData>) {
-  const { id, runId, userId } = job.data;
-  logger.log('info', `Processing scheduled workflow job for robotId: ${id}, runId: ${runId}, userId: ${userId}`);
-  
-  try {
-    // Execute the workflow using the existing handleRunRecording function
-    await handleRunRecording(id, userId);
-    
-    // Update the robot's schedule with last run and next run times
-    const robot = await Robot.findOne({ where: { 'recording_meta.id': id } });
-    if (robot && robot.schedule && robot.schedule.cronExpression && robot.schedule.timezone) {
-      // Update lastRunAt to the current time
-      const lastRunAt = new Date();
-      
-      // Compute the next run date
-      const nextRunAt = computeNextRun(robot.schedule.cronExpression, robot.schedule.timezone) || undefined;
-      
+
+async function claimDueDbSchedules(): Promise<DbScheduledRobot[]> {
+  const now = new Date();
+  const claimExpiry = new Date(now.getTime() - DB_SCHEDULER_CLAIM_TIMEOUT_MS);
+
+  return sequelize.transaction(async (transaction) => {
+    const lockResult = await sequelize.query<{ locked: boolean }>(
+      'SELECT pg_try_advisory_xact_lock(:lockKey) AS locked',
+      { replacements: { lockKey: DB_SCHEDULER_ADVISORY_LOCK_KEY }, type: QueryTypes.SELECT, transaction }
+    );
+
+    if (!lockResult[0]?.locked) return [];
+
+    const dueRobots = await Robot.findAll({
+      where: {
+        schedule: { [Op.ne]: null },
+        [Op.and]: [
+          Sequelize.literal(`schedule->>'cronExpression' IS NOT NULL`),
+          Sequelize.literal(`schedule->>'timezone' IS NOT NULL`),
+          Sequelize.literal(`schedule->>'nextRunAt' IS NOT NULL`),
+          Sequelize.literal(`schedule->>'nextRunAt' <= '${now.toISOString()}'`),
+          {
+            [Op.or]: [
+              Sequelize.literal(`schedule->>'schedulerClaimedAt' IS NULL`),
+              Sequelize.literal(`schedule->>'schedulerClaimedAt' < '${claimExpiry.toISOString()}'`),
+            ],
+          },
+        ],
+      },
+      attributes: [
+        'id',
+        'userId',
+        'schedule',
+        [Sequelize.literal(`recording_meta->>'id'`), 'robotMetaId'],
+      ],
+      limit: DB_SCHEDULER_BATCH_SIZE,
+      order: [Sequelize.literal(`schedule->>'nextRunAt' ASC`)],
+      lock: transaction.LOCK.UPDATE,
+      skipLocked: true,
+      transaction,
+    });
+
+    const claimed: DbScheduledRobot[] = [];
+
+    for (const robot of dueRobots) {
+      const robotMetaId = robot.get('robotMetaId') as string | undefined;
+      if (!robotMetaId) continue;
+
       await robot.update({
-        schedule: {
-          ...robot.schedule,
-          lastRunAt,
-          nextRunAt,
-        },
-      });
-      
-      logger.log('info', `Updated robot ${id} schedule - next run at: ${nextRunAt}`);
-    } else {
-      logger.log('error', `Robot ${id} schedule, cronExpression, or timezone is missing.`);
+        schedule: { ...robot.schedule, schedulerClaimedAt: now } as any,
+      }, { transaction });
+
+      claimed.push({ id: robot.id, robotMetaId, userId: String(robot.userId) });
     }
-    
-    return { success: true };
+
+    return claimed;
+  });
+}
+
+async function finalizeSchedule(robotMetaId: string, executedAt: Date): Promise<void> {
+  try {
+    const robot = await Robot.findOne({ where: { 'recording_meta.id': robotMetaId }, attributes: ['id', 'schedule'] });
+    if (!robot || !robot.schedule?.cronExpression || !robot.schedule?.timezone) return;
+
+    const nextRunAt = computeNextRun(robot.schedule.cronExpression, robot.schedule.timezone) || undefined;
+
+    await robot.update({
+      schedule: {
+        ...robot.schedule,
+        schedulerClaimedAt: undefined,
+        lastRunAt: executedAt,
+        nextRunAt,
+      } as any,
+    });
+
+    logger.log('info', `Updated robot ${robotMetaId} schedule - next run at: ${nextRunAt}`);
   } catch (error: unknown) {
     const errorMessage = error instanceof Error ? error.message : String(error);
-    logger.log('error', `Scheduled workflow job failed: ${errorMessage}`);
-    return { success: false };
+    logger.log('error', `Failed to finalize schedule for robot ${robotMetaId}: ${errorMessage}`);
   }
 }
 
-/**
- * Register a worker to handle scheduled workflow jobs
- */
-async function registerScheduledWorkflowWorker() {
+async function releaseScheduleClaim(robotMetaId: string): Promise<void> {
   try {
-    const jobs = await pgBoss.getSchedules();
-    for (const job of jobs) {
-      await pgBoss.createQueue(job.name);
-      await registerWorkerForQueue(job.name);
-    }
-    
-    logger.log('info', 'Scheduled workflow workers registered successfully');
+    const robot = await Robot.findOne({ where: { 'recording_meta.id': robotMetaId }, attributes: ['id', 'schedule'] });
+    if (!robot?.schedule) return;
+
+    await robot.update({ schedule: { ...robot.schedule, schedulerClaimedAt: undefined } as any });
   } catch (error: unknown) {
     const errorMessage = error instanceof Error ? error.message : String(error);
-    logger.log('error', `Failed to register scheduled workflow workers: ${errorMessage}`);
+    logger.log('error', `Failed to release schedule claim for robot ${robotMetaId}: ${errorMessage}`);
   }
 }
 
-/**
- * Register a worker for a specific queue
- * Exported to allow dynamic registration when new schedules are created
- */
-export async function registerWorkerForQueue(queueName: string) {
+async function processDueSchedules(): Promise<void> {
+  if (dbScheduleTickRunning) return;
+  dbScheduleTickRunning = true;
+
   try {
-    if (registeredQueues.has(queueName)) {
-      return;
-    }
-    
-    await pgBoss.work(queueName, async (job: Job<ScheduledWorkflowData> | Job<ScheduledWorkflowData>[]) => {
+    const claimedRobots = await claimDueDbSchedules();
+
+    for (const robot of claimedRobots) {
+      const executedAt = new Date();
+      let dispatched = false;
+
       try {
-        const singleJob = Array.isArray(job) ? job[0] : job;
-        return await processScheduledWorkflow(singleJob);
+        logger.log('info', `Dispatching scheduled workflow for robot ${robot.robotMetaId}`);
+        await addJob(QUEUE_NAMES.SCHEDULED_WORKFLOW, { robotMetaId: robot.robotMetaId, userId: robot.userId }, { maxAttempts: 6 });
+        dispatched = true;
       } catch (error: unknown) {
         const errorMessage = error instanceof Error ? error.message : String(error);
-        logger.log('error', `Scheduled workflow job failed in queue ${queueName}: ${errorMessage}`);
-        throw error;
+        logger.log('error', `Scheduled workflow dispatch failed for robot ${robot.robotMetaId}: ${errorMessage}`);
+      } finally {
+        if (dispatched) {
+          await finalizeSchedule(robot.robotMetaId, executedAt);
+        } else {
+          await releaseScheduleClaim(robot.robotMetaId);
+        }
       }
+    }
+  } catch (error: unknown) {
+    const errorMessage = error instanceof Error ? error.message : String(error);
+    logger.log('error', `Failed to process DB-backed schedules: ${errorMessage}`);
+  } finally {
+    dbScheduleTickRunning = false;
+  }
+}
+
+export async function startScheduleWorker(): Promise<void> {
+  if (scheduleWorkerStarted) {
+    logger.log('warn', 'Schedule worker already started, skipping...');
+    return;
+  }
+
+  setImmediate(() => {
+    processDueSchedules().catch((error) => {
+      logger.log('error', `Initial DB schedule poll failed: ${error instanceof Error ? error.message : String(error)}`);
     });
-    
-    registeredQueues.add(queueName);
-    logger.log('info', `Registered worker for queue: ${queueName}`);
-  } catch (error: unknown) {
-    const errorMessage = error instanceof Error ? error.message : String(error);
-    logger.log('error', `Failed to register worker for queue ${queueName}: ${errorMessage}`);
-  }
+  });
+
+  const interval = setInterval(() => {
+    processDueSchedules().catch((error) => {
+      logger.log('error', `DB schedule poll failed: ${error instanceof Error ? error.message : String(error)}`);
+    });
+  }, DB_SCHEDULER_POLL_MS);
+
+  workerIntervals.push(interval);
+  scheduleWorkerStarted = true;
+  logger.log('info', `DB-backed schedule worker started (${DB_SCHEDULER_POLL_MS / 1000}s interval)`);
 }
 
-/**
- * Initialize PgBoss and register scheduling workers
- */
-async function startScheduleWorker() {
-  try {
-    logger.log('info', 'Starting PgBoss scheduling worker...');
-    await pgBoss.start();
-    logger.log('info', 'PgBoss scheduling worker started successfully');
+export async function stopScheduleWorker(): Promise<void> {
+  if (!scheduleWorkerStarted) return;
 
-    // Register the scheduled workflow worker
-    await registerScheduledWorkflowWorker();
-
-    logger.log('info', 'Scheduling worker registered successfully');
-  } catch (error: unknown) {
-    const errorMessage = error instanceof Error ? error.message : String(error);
-    logger.log('error', `Failed to start PgBoss scheduling worker: ${errorMessage}`);
-    process.exit(1);
+  for (const interval of workerIntervals.splice(0)) {
+    clearInterval(interval);
   }
+
+  scheduleWorkerStarted = false;
+  dbScheduleTickRunning = false;
+  logger.log('info', 'Schedule worker stopped');
 }
-
-startScheduleWorker();
-
-pgBoss.on('error', (error) => {
-  logger.log('error', `PgBoss scheduler error: ${error.message}`);
-});
-
-process.on('SIGTERM', async () => {
-  logger.log('info', 'SIGTERM received, shutting down PgBoss scheduler...');
-  await pgBoss.stop();
-  logger.log('info', 'PgBoss scheduler stopped, ready for termination');
-});
-
-process.on('SIGINT', async () => {
-  logger.log('info', 'SIGINT received, shutting down PgBoss scheduler...');
-  await pgBoss.stop();
-  logger.log('info', 'PgBoss scheduler stopped, waiting for main process cleanup...');
-});
diff --git a/server/src/server.ts b/server/src/server.ts
index d5b5e5b7..fe8ed2ba 100644
--- a/server/src/server.ts
+++ b/server/src/server.ts
@@ -12,7 +12,6 @@ import sequelize, { connectDB, syncDB } from './storage/db'
 import cookieParser from 'cookie-parser';
 import { SERVER_PORT } from "./constants/config";
 import { readdirSync } from "fs"
-import { fork } from 'child_process';
 import { capture } from "./utils/analytics";
 import swaggerUi from 'swagger-ui-express';
 import swaggerSpec from './swagger/config';
@@ -20,8 +19,9 @@ import connectPgSimple from 'connect-pg-simple';
 import pg from 'pg';
 import session from 'express-session';
 import { processQueuedRuns, recoverOrphanedRuns } from './routes/storage';
-import { startWorkers } from './pgboss-worker';
-import { stopPgBossClient, startPgBossClient } from './storage/pgboss'
+import { startWorkers, stopWorkers } from './task-runner';
+import { startGraphileWorkerUtils, stopGraphileWorkerUtils } from './storage/graphileWorker';
+import { startScheduleWorker, stopScheduleWorker } from './schedule-worker';
 import Run from './models/Run';
 
 const normalizeOrigin = (urlString?: string): string => {
@@ -135,11 +135,6 @@ readdirSync(path.join(__dirname, 'api')).forEach((r) => {
 });
 
 const isProduction = process.env.NODE_ENV === 'production';
-const workerPath = path.resolve(__dirname, isProduction ? './schedule-worker.js' : './schedule-worker.ts');
-const recordingWorkerPath = path.resolve(__dirname, isProduction ? './pgboss-worker.js' : './pgboss-worker.ts');
-
-let workerProcess: any;
-let recordingWorkerProcess: any;
 
 app.get('/', function (req, res) {
   capture(
@@ -177,9 +172,9 @@ if (require.main === module) {
 
       await recoverOrphanedRuns();
 
-      await startPgBossClient();
-
+      await startGraphileWorkerUtils();
       await startWorkers();
+      await startScheduleWorker();
 
       io.of('/queued-run').on('connection', (socket) => {
         const userId = socket.handshake.query.userId as string;
@@ -206,55 +201,7 @@ if (require.main === module) {
         }
       });
 
-      if (!isProduction) {
-        // Development mode
-        if (process.platform === 'win32') {
-          workerProcess = fork(workerPath, [], {
-            execArgv: ['--inspect=5859'],
-          });
-          workerProcess.on('message', (message: any) => {
-            console.log(`Message from worker: ${message}`);
-          });
-          workerProcess.on('error', (error: any) => {
-            console.error(`Error in worker: ${error}`);
-          });
-          workerProcess.on('exit', (code: any) => {
-            console.log(`Worker exited with code: ${code}`);
-          });
-
-          recordingWorkerProcess = fork(recordingWorkerPath, [], {
-            execArgv: ['--inspect=5860'],
-          });
-          recordingWorkerProcess.on('message', (message: any) => {
-            console.log(`Message from recording worker: ${message}`);
-          });
-          recordingWorkerProcess.on('error', (error: any) => {
-            console.error(`Error in recording worker: ${error}`);
-          });
-          recordingWorkerProcess.on('exit', (code: any) => {
-            console.log(`Recording worker exited with code: ${code}`);
-          });
-        } else {
-          // Run in same process for non-Windows development
-          try {
-            await import('./schedule-worker');
-            await import('./pgboss-worker');
-            console.log('Workers started in main process for memory sharing');
-          } catch (error) {
-            console.error('Failed to start workers in main process:', error);
-          }
-        }
-      } else {
-        // Production mode - run workers in same process for memory sharing
-        try {
-          await import('./schedule-worker');
-          await import('./pgboss-worker');
-          logger.log('info', 'Workers started in main process');
-        } catch (error: any) {
-          logger.log('error', `Failed to start workers: ${error.message}`);
-          process.exit(1);
-        }
-      }
+      logger.log('info', 'All workers started in main process');
 
       logger.log('info', `Server listening on port ${SERVER_PORT}`);
     } catch (error: any) {
@@ -345,19 +292,12 @@ if (require.main === module) {
       console.error('Error during browser cleanup:', error.message);
     }
 
-    if (!isProduction) {
-      try {
-        if (workerProcess) {
-          workerProcess.kill('SIGTERM');
-        }
-        if (recordingWorkerProcess) {
-          recordingWorkerProcess.kill('SIGTERM');
-        }
-      } catch (workerError: any) {
-        console.error('Error terminating worker processes:', workerError.message);
-      }
-
-      await new Promise(resolve => setTimeout(resolve, 1000));
+    try {
+      await stopScheduleWorker();
+      await stopWorkers();
+      await stopGraphileWorkerUtils();
+    } catch (workerError: any) {
+      console.error('Error stopping workers:', workerError.message);
     }
 
     try {
@@ -392,12 +332,6 @@ if (require.main === module) {
       shutdownSuccessful = false;
     }
 
-    try {
-      await stopPgBossClient();
-    } catch (pgBossError: any) {
-      console.error('Error closing PgBoss client connection:', pgBossError.message);
-      shutdownSuccessful = false;
-    }
 
     try {
       await sequelize.close();
diff --git a/server/src/storage/graphileWorker.ts b/server/src/storage/graphileWorker.ts
new file mode 100644
index 00000000..d716cb1a
--- /dev/null
+++ b/server/src/storage/graphileWorker.ts
@@ -0,0 +1,79 @@
+import { makeWorkerUtils, WorkerUtils } from 'graphile-worker';
+import { Pool } from 'pg';
+import logger from '../logger';
+import dotenv from 'dotenv';
+
+dotenv.config();
+
+if (!process.env.DB_USER || !process.env.DB_PASSWORD || !process.env.DB_HOST || !process.env.DB_PORT || !process.env.DB_NAME) {
+  throw new Error('One or more required environment variables are missing.');
+}
+
+const connectionString = `postgres://${process.env.DB_USER}:${encodeURIComponent(process.env.DB_PASSWORD!)}@${process.env.DB_HOST}:${process.env.DB_PORT}/${process.env.DB_NAME}`;
+const useSSL = process.env.DB_SSL === 'true';
+
+let utilsPool: Pool | null = null;
+let workerUtils: WorkerUtils | null = null;
+let isStarted = false;
+
+export async function startGraphileWorkerUtils(): Promise<void> {
+  if (isStarted) {
+    logger.log('warn', 'Graphile Worker utils already started, skipping...');
+    return;
+  }
+
+  try {
+    utilsPool = new Pool({
+      connectionString,
+      max: 3,
+      ssl: useSSL ? true : undefined,
+    });
+
+    workerUtils = await makeWorkerUtils({ pgPool: utilsPool });
+    await workerUtils.migrate();
+    isStarted = true;
+    logger.log('info', 'Graphile Worker utils started');
+  } catch (error: any) {
+    logger.log('error', `Failed to start Graphile Worker utils: ${error.message}`);
+    throw error;
+  }
+}
+
+export async function stopGraphileWorkerUtils(): Promise<void> {
+  if (!isStarted) return;
+
+  try {
+    if (workerUtils) {
+      await workerUtils.release();
+      workerUtils = null;
+    }
+    if (utilsPool) {
+      await utilsPool.end();
+      utilsPool = null;
+    }
+    isStarted = false;
+    logger.log('info', 'Graphile Worker utils stopped');
+  } catch (error: any) {
+    logger.log('error', `Failed to stop Graphile Worker utils: ${error.message}`);
+  }
+}
+
+export async function addJob(
+  taskIdentifier: string,
+  payload: Record<string, unknown>,
+  options?: { maxAttempts?: number; runAt?: Date; jobKey?: string },
+): Promise<string> {
+  if (!workerUtils) {
+    throw new Error('Graphile Worker utils not initialized — call startGraphileWorkerUtils first');
+  }
+  const job = await workerUtils.addJob(taskIdentifier, payload, options);
+  return String(job.id);
+}
+
+process.on('SIGTERM', async () => {
+  await stopGraphileWorkerUtils();
+});
+
+process.on('SIGINT', async () => {
+  await stopGraphileWorkerUtils();
+});
diff --git a/server/src/storage/schedule.ts b/server/src/storage/schedule.ts
index ed524d9b..2da3ee99 100644
--- a/server/src/storage/schedule.ts
+++ b/server/src/storage/schedule.ts
@@ -1,37 +1,25 @@
-/**
- * Shared scheduling utilities
- * These functions use the shared PgBoss client to avoid connection leaks
- */
-import { v4 as uuid } from 'uuid';
 import logger from '../logger';
-import { pgBossClient } from './pgboss';
-import { registerWorkerForQueue } from '../schedule-worker';
+import Robot from '../models/Robot';
+import { computeNextRun } from '../utils/schedule';
 
-/**
- * Utility function to schedule a cron job using PgBoss
- * @param id The robot ID
- * @param userId The user ID
- * @param cronExpression The cron expression for scheduling
- * @param timezone The timezone for the cron expression
- */
-export async function scheduleWorkflow(id: string, userId: string,  cronExpression: string, timezone: string): Promise<void> {
+export async function scheduleWorkflow(id: string, userId: string, cronExpression: string, timezone: string): Promise<void> {
   try {
-    const runId = uuid();
+    const robot = await Robot.findOne({ where: { 'recording_meta.id': id } });
+    if (!robot) throw new Error(`Robot ${id} not found`);
 
-    const queueName = `scheduled-workflow-${id}`;
+    const nextRunAt = computeNextRun(cronExpression, timezone) || undefined;
 
-    logger.log('info', `Scheduling workflow ${id} with cron expression ${cronExpression} in timezone ${timezone}`);
+    await robot.update({
+      schedule: {
+        ...robot.schedule,
+        cronExpression,
+        timezone,
+        nextRunAt,
+        schedulerClaimedAt: undefined,
+      } as any,
+    });
 
-    await pgBossClient.createQueue(queueName);
-
-    await pgBossClient.schedule(queueName, cronExpression,
-      { id, runId, userId },
-      { tz: timezone }
-    );
-
-    await registerWorkerForQueue(queueName);
-
-    logger.log('info', `Scheduled workflow job for robot ${id}`);
+    logger.log('info', `Scheduled robot ${id} (cron: ${cronExpression}, tz: ${timezone}, next: ${nextRunAt})`);
   } catch (error: unknown) {
     const errorMessage = error instanceof Error ? error.message : String(error);
     logger.log('error', `Failed to schedule workflow: ${errorMessage}`);
@@ -39,33 +27,27 @@ export async function scheduleWorkflow(id: string, userId: string,  cronExpressi
   }
 }
 
-/**
- * Utility function to cancel a scheduled job
- * @param robotId The robot ID
- * @returns true if successful
- */
-export async function cancelScheduledWorkflow(robotId: string) {
+export async function cancelScheduledWorkflow(robotId: string): Promise<boolean> {
   try {
-    const jobs = await pgBossClient.getSchedules();
+    const robot = await Robot.findOne({ where: { 'recording_meta.id': robotId } });
+    if (!robot) return true;
 
-    const matchingJobs = jobs.filter((job: any) => {
-      try {
-        const data = job.data;
-        return data && data.id === robotId;
-      } catch {
-        return false;
-      }
-    });
-
-    for (const job of matchingJobs) {
-      logger.log('info', `Cancelling scheduled job ${job.name} for robot ${robotId}`);
-      await pgBossClient.unschedule(job.name);
+    if (robot.schedule) {
+      await robot.update({
+        schedule: {
+          ...robot.schedule,
+          cronExpression: undefined,
+          nextRunAt: undefined,
+          schedulerClaimedAt: undefined,
+        } as any,
+      });
     }
 
+    logger.log('info', `Cancelled schedule for robot ${robotId}`);
     return true;
   } catch (error: unknown) {
     const errorMessage = error instanceof Error ? error.message : String(error);
     logger.log('error', `Failed to cancel scheduled workflow: ${errorMessage}`);
     throw error;
   }
-}
\ No newline at end of file
+}
diff --git a/server/src/task-runner.ts b/server/src/task-runner.ts
new file mode 100644
index 00000000..3db40518
--- /dev/null
+++ b/server/src/task-runner.ts
@@ -0,0 +1,672 @@
+import { run, Runner, TaskList } from 'graphile-worker';
+import { Pool } from 'pg';
+import logger from './logger';
+import {
+  initializeRemoteBrowserForRecording,
+  destroyRemoteBrowser,
+  interpretWholeWorkflow,
+  stopRunningInterpretation,
+} from './browser-management/controller';
+import { WorkflowFile } from 'maxun-core';
+import Run from './models/Run';
+import Robot from './models/Robot';
+import { browserPool } from './server';
+import { Page } from 'playwright-core';
+import { capture } from './utils/analytics';
+import { addGoogleSheetUpdateTask, processGoogleSheetUpdates } from './workflow-management/integrations/gsheet';
+import { addAirtableUpdateTask, processAirtableUpdates } from './workflow-management/integrations/airtable';
+import { io as serverIo } from './server';
+import { sendWebhook } from './routes/webhook';
+import { BinaryOutputService } from './storage/mino';
+import { convertPageToMarkdown, convertPageToHTML, convertPageToLinks, convertPageToScreenshot, convertPageToText } from './markdownify/scrape';
+import { executeBrowserAgent } from './sdk/browserAgent';
+import { processRobotOutputFormats } from './utils/output-post-processor';
+import { getInterpretationFailureReason, hasExpectedRobotOutput } from './utils/output-validation';
+import { handleRunRecording } from './workflow-management/scheduler';
+import dotenv from 'dotenv';
+
+dotenv.config();
+
+if (!process.env.DB_USER || !process.env.DB_PASSWORD || !process.env.DB_HOST || !process.env.DB_PORT || !process.env.DB_NAME) {
+  throw new Error('Failed to start task runner: one or more required environment variables are missing.');
+}
+
+const connectionString = `postgresql://${process.env.DB_USER}:${encodeURIComponent(process.env.DB_PASSWORD!)}@${process.env.DB_HOST}:${process.env.DB_PORT}/${process.env.DB_NAME}`;
+const useSSL = process.env.DB_SSL === 'true';
+
+export const QUEUE_NAMES = {
+  INITIALIZE_BROWSER_RECORDING: 'initialize-browser-recording',
+  DESTROY_BROWSER: 'destroy-browser',
+  INTERPRET_WORKFLOW: 'interpret-workflow',
+  STOP_INTERPRETATION: 'stop-interpretation',
+  EXECUTE_RUN: 'execute-run',
+  ABORT_RUN: 'abort-run',
+  SCHEDULED_WORKFLOW: 'scheduled-workflow',
+} as const;
+
+interface InitializeBrowserData {
+  userId: string;
+}
+
+interface InterpretWorkflow {
+  userId: string;
+}
+
+interface StopInterpretWorkflow {
+  userId: string;
+}
+
+interface DestroyBrowserData {
+  browserId: string;
+  userId: string;
+}
+
+interface ExecuteRunData {
+  userId: string;
+  runId: string;
+  browserId: string;
+}
+
+interface AbortRunData {
+  userId: string;
+  runId: string;
+}
+
+interface ScheduledWorkflowData {
+  robotMetaId: string;
+  userId: string;
+}
+
+const TOTAL_CONCURRENCY = Math.max(1, parseInt(process.env.WORKER_CONCURRENCY || '10', 10));
+
+function AddGeneratedFlags(workflow: WorkflowFile) {
+  const copy = JSON.parse(JSON.stringify(workflow));
+  for (let i = 0; i < workflow.workflow.length; i++) {
+    copy.workflow[i].what.unshift({
+      action: 'flag',
+      args: ['generated'],
+    });
+  }
+  return copy;
+}
+
+function withTimeout<T>(promise: Promise<T>, timeoutMs: number, operation: string): Promise<T> {
+  return Promise.race([
+    promise,
+    new Promise<T>((_, reject) =>
+      setTimeout(() => reject(new Error(`${operation} timed out after ${timeoutMs}ms`)), timeoutMs)
+    )
+  ]);
+}
+
+async function triggerIntegrationUpdates(runId: string, robotMetaId: string): Promise<void> {
+  try {
+    addGoogleSheetUpdateTask(runId, { robotId: robotMetaId, runId, status: 'pending', retries: 5 });
+    addAirtableUpdateTask(runId, { robotId: robotMetaId, runId, status: 'pending', retries: 5 });
+
+    withTimeout(processAirtableUpdates(), 65000, 'Airtable update')
+      .catch(err => logger.log('error', `Airtable update error: ${err.message}`));
+    withTimeout(processGoogleSheetUpdates(), 65000, 'Google Sheets update')
+      .catch(err => logger.log('error', `Google Sheets update error: ${err.message}`));
+  } catch (err: any) {
+    logger.log('error', `Failed to update integrations for run: ${runId}: ${err.message}`);
+  }
+}
+
+const getRobotTargetUrl = (recording: any): string => {
+  const metaUrl = recording?.recording_meta?.url?.trim();
+  if (metaUrl) return metaUrl;
+
+  const workflow = recording?.recording?.workflow || [];
+  const entryPair = [...workflow].reverse().find((pair: any) =>
+    pair?.what?.some((action: any) => action.action === 'goto' && typeof action.args?.[0] === 'string' && action.args[0] !== 'about:blank'),
+  );
+  const gotoUrl = entryPair?.what?.find((action: any) => action.action === 'goto' && typeof action.args?.[0] === 'string')?.args?.[0]?.trim();
+  if (gotoUrl) return gotoUrl;
+
+  return workflow.find((pair: any) => typeof pair?.where?.url === 'string' && pair.where.url !== 'about:blank')?.where?.url?.trim() || '';
+};
+
+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();
+    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);
+    const browserWaitStart = Date.now();
+    let lastLogTime = 0;
+    let pollAttempts = 0;
+    const MAX_POLL_ATTEMPTS = Math.ceil(BROWSER_INIT_TIMEOUT / 2000);
+
+    while (!browser && (Date.now() - browserWaitStart) < BROWSER_INIT_TIMEOUT && pollAttempts < MAX_POLL_ATTEMPTS) {
+      const currentTime = Date.now();
+      pollAttempts++;
+
+      const browserStatus = browserPool.getBrowserStatus(browserId);
+      if (browserStatus === null) throw new Error(`Browser slot ${browserId} does not exist in pool`);
+      if (browserStatus === 'failed') throw new Error(`Browser ${browserId} initialization failed`);
+
+      if (currentTime - lastLogTime > 10000) {
+        logger.log('info', `Browser ${browserId} not ready yet (status: ${browserStatus}), waiting... (${Math.round((currentTime - browserWaitStart) / 1000)}s elapsed)`);
+        lastLogTime = currentTime;
+      }
+
+      await new Promise(resolve => setTimeout(resolve, 2000));
+      browser = browserPool.getRemoteBrowser(browserId);
+    }
+
+    if (!browser) {
+      const finalStatus = browserPool.getBrowserStatus(browserId);
+      throw new Error(`Browser ${browserId} not found in pool after ${BROWSER_INIT_TIMEOUT / 1000}s timeout (final status: ${finalStatus})`);
+    }
+
+    logger.log('info', `Browser ${browserId} found and ready for execution`);
+
+    try {
+      const recording = await Robot.findOne({ where: { 'recording_meta.id': plainRun.robotMetaId }, raw: true });
+      if (!recording) throw new Error(`Recording for run ${data.runId} not found`);
+
+      let currentPage = browser.getCurrentPage();
+      const pageWaitStart = Date.now();
+      let lastPageLogTime = 0;
+      let pageAttempts = 0;
+
+      while (!currentPage && (Date.now() - pageWaitStart) < BROWSER_PAGE_TIMEOUT && pageAttempts < 15) {
+        const currentTime = Date.now();
+        pageAttempts++;
+        if (currentTime - lastPageLogTime > 5000) {
+          logger.log('info', `Page not ready for browser ${browserId}, waiting...`);
+          lastPageLogTime = currentTime;
+        }
+        await new Promise(resolve => setTimeout(resolve, 1000));
+        currentPage = browser.getCurrentPage();
+      }
+
+      if (!currentPage) throw new Error(`No current page available for browser ${browserId} after ${BROWSER_PAGE_TIMEOUT / 1000}s timeout`);
+
+      if (recording.recording_meta.type === 'scrape') {
+        logger.log('info', `Executing scrape robot for run ${data.runId}`);
+
+        const rawFormats = run.interpreterSettings?.formats || recording.recording_meta.formats;
+        const formats = rawFormats && rawFormats.length > 0 ? rawFormats : ['markdown'];
+
+        await run.update({ status: 'running', log: `Converting page to ${formats.join(', ')}` });
+
+        try {
+          const url = getRobotTargetUrl(recording);
+          if (!url) throw new Error('No URL specified for scrape robot');
+
+          const serializableOutput: any = {};
+          const binaryOutput: any = {};
+          const SCRAPE_TIMEOUT = 120000;
+
+          if (formats.includes('screenshot-visible')) {
+            const buf = await Promise.race([convertPageToScreenshot(url, currentPage, false), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+            if (!binaryOutput['screenshot-visible']) binaryOutput['screenshot-visible'] = { data: buf.toString('base64'), mimeType: 'image/png' };
+          }
+
+          if (formats.includes('screenshot-fullpage')) {
+            const buf = await Promise.race([convertPageToScreenshot(url, currentPage, true), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+            if (!binaryOutput['screenshot-fullpage']) binaryOutput['screenshot-fullpage'] = { data: buf.toString('base64'), mimeType: 'image/png' };
+          }
+
+          if (formats.includes('text')) {
+            const text = await Promise.race([convertPageToText(url, currentPage), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+            if (text) serializableOutput.text = [{ content: text }];
+          }
+
+          if (formats.includes('markdown')) {
+            const markdown = await Promise.race([convertPageToMarkdown(url, currentPage), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+            serializableOutput.markdown = [{ content: markdown }];
+          }
+
+          if (formats.includes('html')) {
+            const html = await Promise.race([convertPageToHTML(url, currentPage), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+            serializableOutput.html = [{ content: html }];
+          }
+
+          if (formats.includes('links')) {
+            try {
+              const links = await Promise.race([convertPageToLinks(url, currentPage), new Promise<never>((_, r) => setTimeout(() => r(new Error('timeout')), SCRAPE_TIMEOUT))]);
+              if (links && links.length > 0) serializableOutput.links = links.map((link: string) => ({ url: link }));
+            } catch (error: any) {
+              logger.log('warn', `Links extraction failed for run ${data.runId}: ${error.message}`);
+            }
+          }
+
+          const promptInstructions = run.interpreterSettings?.promptInstructions || (recording.recording_meta as any).promptInstructions as string | undefined;
+          if (promptInstructions) {
+            try {
+              const llmConfig = {
+                provider: ((recording.recording_meta as any).promptLlmProvider || 'ollama') as 'anthropic' | 'openai' | 'ollama',
+                model: (recording.recording_meta as any).promptLlmModel as string | undefined,
+                apiKey: (recording.recording_meta as any).promptLlmApiKey as string | undefined,
+                baseUrl: (recording.recording_meta as any).promptLlmBaseUrl as string | undefined,
+              };
+              await run.update({ log: 'Running smart query...' });
+              const agentResult = await executeBrowserAgent(currentPage, promptInstructions, llmConfig);
+              serializableOutput.promptResult = [{ content: agentResult.result, steps: agentResult.steps }];
+            } catch (agentError: any) {
+              logger.log('warn', `Smart query failed for run ${data.runId}: ${agentError.message}`);
+              serializableOutput.promptResult = [{ content: `Smart query failed: ${agentError.message}`, steps: [] }];
+            }
+          }
+
+          await run.update({ status: 'success', finishedAt: new Date().toLocaleString(), log: `${formats.join(', ').toUpperCase()} conversion completed successfully`, serializableOutput, binaryOutput });
+
+          let uploadedBinaryOutput: Record<string, string> = {};
+          if (Object.keys(binaryOutput).length > 0) {
+            const svc = new BinaryOutputService('maxun-run-screenshots');
+            uploadedBinaryOutput = await svc.uploadAndStoreBinaryOutput(run, binaryOutput);
+            await run.update({ binaryOutput: uploadedBinaryOutput });
+          }
+
+          try {
+            const completionData = { runId: data.runId, robotMetaId: plainRun.robotMetaId, robotName: recording.recording_meta.name, status: 'success', finishedAt: new Date().toLocaleString() };
+            serverIo.of(browserId).emit('run-completed', completionData);
+            serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-completed', completionData);
+          } catch (socketError: any) {
+            logger.log('warn', `Failed to send run-completed notification for run ${data.runId}: ${socketError.message}`);
+          }
+
+          try {
+            await sendWebhook(plainRun.robotMetaId, 'run_completed', { runId: data.runId, robotId: plainRun.robotMetaId, robotName: recording.recording_meta.name, status: 'success', finishedAt: new Date().toLocaleString() });
+          } catch (webhookError: any) {
+            logger.log('warn', `Failed to send webhooks for run ${data.runId}: ${webhookError.message}`);
+          }
+
+          capture('maxun-oss-run-created', { runId: data.runId, user_id: data.userId, status: 'success', robot_type: 'scrape', formats, source: 'manual' });
+          await destroyRemoteBrowser(browserId, data.userId);
+          return;
+
+        } catch (error: any) {
+          logger.log('error', `Scrape conversion failed for run ${data.runId}: ${error.message}`);
+          await run.update({ status: 'failed', finishedAt: new Date().toLocaleString(), log: `Conversion failed: ${error.message}` });
+          try {
+            const failureData = { runId: data.runId, robotMetaId: plainRun.robotMetaId, robotName: recording.recording_meta.name, status: 'failed', finishedAt: new Date().toLocaleString() };
+            serverIo.of(browserId).emit('run-completed', failureData);
+            serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-completed', failureData);
+          } catch (_) {}
+          capture('maxun-oss-run-created', { runId: data.runId, user_id: data.userId, status: 'failed', robot_type: 'scrape', source: 'manual' });
+          await destroyRemoteBrowser(browserId, data.userId);
+          throw error;
+        }
+      }
+
+      const isRunAborted = async (): Promise<boolean> => {
+        try {
+          const currentRun = await Run.findOne({ where: { runId: data.runId } });
+          return currentRun ? (currentRun.status === 'aborted' || currentRun.status === 'aborting') : false;
+        } catch { return false; }
+      };
+
+      logger.log('info', `Starting workflow execution for run ${data.runId}`);
+      await run.update({ status: 'running', log: 'Workflow execution started' });
+
+      try {
+        const startedData = { runId: data.runId, robotMetaId: plainRun.robotMetaId, robotName: recording.recording_meta.name, status: 'running', startedAt: new Date().toLocaleString() };
+        serverIo.of(browserId).emit('run-started', startedData);
+        serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-started', startedData);
+      } catch (socketError: any) {
+        logger.log('warn', `Failed to send run-started notification for run ${data.runId}: ${socketError.message}`);
+      }
+
+      browser.interpreter.setRunId(data.runId);
+
+      const INTERPRETATION_TIMEOUT = 600000;
+      const interpretationPromise = browser.interpreter.InterpretRecording(
+        AddGeneratedFlags(recording.recording),
+        currentPage,
+        (newPage: Page) => currentPage = newPage,
+        plainRun.interpreterSettings,
+      );
+
+      const interpretationInfo = await Promise.race([
+        interpretationPromise,
+        new Promise<never>((_, reject) => setTimeout(() => reject(new Error(`Workflow interpretation timed out after ${INTERPRETATION_TIMEOUT / 1000}s`)), INTERPRETATION_TIMEOUT))
+      ]);
+
+      if (await isRunAborted()) {
+        logger.log('info', `Run ${data.runId} was aborted during execution, not updating status`);
+        try { await browser.interpreter.clearState(); } catch (_) {}
+        await destroyRemoteBrowser(plainRun.browserId, data.userId);
+        return;
+      }
+
+      logger.log('info', `Workflow execution completed for run ${data.runId}`);
+
+      const finalRun = await Run.findByPk(run.id);
+      const categorizedOutput = {
+        scrapeSchema: finalRun?.serializableOutput?.scrapeSchema || {},
+        scrapeList: finalRun?.serializableOutput?.scrapeList || {},
+        crawl: finalRun?.serializableOutput?.crawl || {},
+        search: finalRun?.serializableOutput?.search || {}
+      };
+
+      let binaryOutput: Record<string, any> = { ...(interpretationInfo.binaryOutput || {}) };
+
+      const robotType = recording.recording_meta.type;
+      const outputFormats = (recording.recording_meta as any).formats as string[] | undefined;
+      if (robotType === 'crawl' || robotType === 'search') {
+        const processedOutput = await processRobotOutputFormats({
+          robotType,
+          outputFormats,
+          categorizedOutput: { crawl: categorizedOutput.crawl as Record<string, any>, search: categorizedOutput.search as Record<string, any> },
+          currentPage,
+          initialBinaryOutput: binaryOutput,
+        });
+
+        categorizedOutput.crawl = processedOutput.categorizedOutput.crawl;
+        categorizedOutput.search = processedOutput.categorizedOutput.search;
+        binaryOutput = processedOutput.binaryOutput;
+
+        const hasOutput = hasExpectedRobotOutput(robotType, { crawl: categorizedOutput.crawl as Record<string, any>, search: categorizedOutput.search as Record<string, any> }, outputFormats, binaryOutput);
+        if (!hasOutput) {
+          const humanRobotType = robotType.charAt(0).toUpperCase() + robotType.slice(1);
+          throw new Error(getInterpretationFailureReason(interpretationInfo.log, `${humanRobotType} run completed without producing output data`));
+        }
+      }
+
+      const binarySvc = new BinaryOutputService('maxun-run-screenshots');
+      const uploadedBinaryOutput = Object.keys(binaryOutput).length > 0 ? await binarySvc.uploadAndStoreBinaryOutput(run, binaryOutput) : {};
+
+      if (await isRunAborted()) {
+        logger.log('info', `Run ${data.runId} was aborted while processing results, not updating status`);
+        return;
+      }
+
+      await run.update({
+        status: 'success',
+        finishedAt: new Date().toLocaleString(),
+        log: interpretationInfo.log.join('\n'),
+        binaryOutput: uploadedBinaryOutput,
+        serializableOutput: { ...(finalRun?.serializableOutput || {}), crawl: categorizedOutput.crawl, search: categorizedOutput.search }
+      });
+
+      let totalSchemaItemsExtracted = 0;
+      let totalListItemsExtracted = 0;
+      if (categorizedOutput.scrapeSchema) Object.values(categorizedOutput.scrapeSchema).forEach((v: any) => { totalSchemaItemsExtracted += Array.isArray(v) ? v.length : (v ? 1 : 0); });
+      if (categorizedOutput.scrapeList) Object.values(categorizedOutput.scrapeList).forEach((v: any) => { totalListItemsExtracted += Array.isArray(v) ? v.length : 0; });
+
+      capture('maxun-oss-run-created', { runId: data.runId, user_id: data.userId, created_at: new Date().toISOString(), status: 'success', totalRowsExtracted: totalSchemaItemsExtracted + totalListItemsExtracted, schemaItemsExtracted: totalSchemaItemsExtracted, listItemsExtracted: totalListItemsExtracted, extractedScreenshotsCount: Object.keys(uploadedBinaryOutput).length, is_llm: (recording.recording_meta as any).isLLM, source: 'manual' });
+
+      try {
+        const completionData = { runId: data.runId, robotMetaId: plainRun.robotMetaId, robotName: recording.recording_meta.name, status: 'success', finishedAt: new Date().toLocaleString() };
+        serverIo.of(browserId).emit('run-completed', completionData);
+        serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-completed', completionData);
+      } catch (socketError: any) {
+        logger.log('warn', `Failed to send run-completed notification for run ${data.runId}: ${socketError.message}`);
+      }
+
+      try {
+        await sendWebhook(plainRun.robotMetaId, 'run_completed', {
+          robot_id: plainRun.robotMetaId, run_id: data.runId, robot_name: recording.recording_meta.name, status: 'success',
+          started_at: plainRun.startedAt, finished_at: new Date().toLocaleString(),
+          extracted_data: {
+            captured_texts: Object.keys(categorizedOutput.scrapeSchema || {}).length > 0 ? Object.entries(categorizedOutput.scrapeSchema).reduce((acc, [name, value]) => { acc[name] = Array.isArray(value) ? value : [value]; return acc; }, {} as Record<string, any[]>) : {},
+            captured_lists: categorizedOutput.scrapeList,
+            crawl_data: categorizedOutput.crawl, search_data: categorizedOutput.search,
+            captured_texts_count: totalSchemaItemsExtracted, captured_lists_count: totalListItemsExtracted, screenshots_count: Object.keys(uploadedBinaryOutput).length
+          },
+          metadata: { browser_id: plainRun.browserId, user_id: data.userId }
+        });
+      } catch (webhookError: any) {
+        logger.log('error', `Failed to send webhooks for run ${data.runId}: ${webhookError.message}`);
+      }
+
+      await triggerIntegrationUpdates(plainRun.runId, plainRun.robotMetaId);
+      await destroyRemoteBrowser(browserId, data.userId);
+      logger.log('info', `Browser ${browserId} destroyed after successful run ${data.runId}`);
+
+    } catch (executionError: any) {
+      logger.log('error', `Run execution failed for run ${data.runId}: ${executionError.message}`);
+
+      const browserId = data.browserId || (run as any).toJSON().browserId;
+      let partialDataExtracted = false;
+
+      try {
+        const hasData = (run.serializableOutput && (
+          (run.serializableOutput.scrapeSchema && run.serializableOutput.scrapeSchema.length > 0) ||
+          (run.serializableOutput.scrapeList && run.serializableOutput.scrapeList.length > 0) ||
+          (run.serializableOutput.crawl && Object.keys(run.serializableOutput.crawl).length > 0) ||
+          (run.serializableOutput.search && Object.keys(run.serializableOutput.search).length > 0))) ||
+          (run.binaryOutput && Object.keys(run.binaryOutput).length > 0);
+        if (hasData) {
+          await triggerIntegrationUpdates((run as any).toJSON().runId, (run as any).toJSON().robotMetaId);
+          partialDataExtracted = true;
+        }
+      } catch (_) {}
+
+      await run.update({ status: 'failed', finishedAt: new Date().toLocaleString(), log: `Failed: ${executionError.message}` });
+
+      const plainRun = (run as any).toJSON();
+      const recording = await Robot.findOne({ where: { 'recording_meta.id': run.robotMetaId }, raw: true });
+
+      try {
+        const failureData = { runId: data.runId, robotMetaId: plainRun.robotMetaId, robotName: recording ? recording.recording_meta.name : 'Unknown Robot', status: 'failed', finishedAt: new Date().toLocaleString(), hasPartialData: partialDataExtracted };
+        serverIo.of(browserId).emit('run-completed', failureData);
+        serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-completed', failureData);
+      } catch (_) {}
+
+      try {
+        await sendWebhook(plainRun.robotMetaId, 'run_failed', {
+          robot_id: plainRun.robotMetaId, run_id: data.runId, robot_name: recording ? recording.recording_meta.name : 'Unknown Robot',
+          status: 'failed', started_at: plainRun.startedAt, finished_at: new Date().toLocaleString(),
+          error: { message: executionError.message, stack: executionError.stack, type: 'ExecutionError' },
+          partial_data_extracted: partialDataExtracted, metadata: { browser_id: plainRun.browserId, user_id: data.userId }
+        });
+      } catch (_) {}
+
+      capture('maxun-oss-run-created', { runId: data.runId, user_id: data.userId, created_at: new Date().toISOString(), status: 'failed', error_message: executionError.message, partial_data_extracted: partialDataExtracted, source: 'manual' });
+
+      try { if (browser && browser.interpreter) await browser.interpreter.clearState(); } catch (_) {}
+      await destroyRemoteBrowser(browserId, data.userId);
+    }
+
+  } catch (error: unknown) {
+    const errorMessage = error instanceof Error ? error.message : String(error);
+    logger.log('error', `Failed to process run execution job: ${errorMessage}`);
+
+    try {
+      const run = await Run.findOne({ where: { runId: data.runId } });
+      if (run) {
+        await run.update({ status: 'failed', finishedAt: new Date().toLocaleString(), log: `Failed: ${errorMessage}` });
+        const recording = await Robot.findOne({ where: { 'recording_meta.id': run.robotMetaId }, raw: true });
+        try {
+          await sendWebhook(run.robotMetaId, 'run_failed', {
+            robot_id: run.robotMetaId, run_id: data.runId, robot_name: recording ? recording.recording_meta.name : 'Unknown Robot',
+            status: 'failed', started_at: run.startedAt, finished_at: new Date().toLocaleString(),
+            error: { message: errorMessage }, metadata: { browser_id: run.browserId, user_id: data.userId }
+          });
+        } catch (_) {}
+        try {
+          serverIo.of(run.browserId).emit('run-completed', { runId: data.runId, robotMetaId: run.robotMetaId, robotName: recording ? recording.recording_meta.name : 'Unknown Robot', status: 'failed', finishedAt: new Date().toLocaleString() });
+          serverIo.of('/queued-run').to(`user-${data.userId}`).emit('run-completed', { runId: data.runId, status: 'failed' });
+        } catch (_) {}
+      }
+    } catch (_) {}
+
+    throw error;
+  }
+}
+
+async function abortRun(runId: string, userId: string): Promise<void> {
+  try {
+    const run = await Run.findOne({ where: { runId } });
+    if (!run) {
+      logger.log('warn', `Run ${runId} not found`);
+      return;
+    }
+
+    await run.update({ status: 'aborting' });
+
+    const plainRun = run.toJSON();
+    const recording = await Robot.findOne({ where: { 'recording_meta.id': plainRun.robotMetaId }, raw: true });
+    const robotName = recording?.recording_meta?.name || 'Unknown Robot';
+
+    let browser;
+    try { browser = browserPool.getRemoteBrowser(plainRun.browserId); } catch { browser = null; }
+
+    if (!browser) {
+      await run.update({ status: 'aborted', finishedAt: new Date().toLocaleString(), log: 'Aborted: Browser not found or already closed' });
+      try { serverIo.of(plainRun.browserId).emit('run-aborted', { runId, robotName, status: 'aborted', finishedAt: new Date().toLocaleString() }); } catch (_) {}
+      return;
+    }
+
+    await run.update({ status: 'aborted', finishedAt: new Date().toLocaleString(), log: 'Run aborted by user' });
+
+    const hasData = (run.serializableOutput && (
+      (run.serializableOutput.scrapeSchema && run.serializableOutput.scrapeSchema.length > 0) ||
+      (run.serializableOutput.scrapeList && run.serializableOutput.scrapeList.length > 0))) ||
+      (run.binaryOutput && Object.keys(run.binaryOutput).length > 0);
+
+    if (hasData) await triggerIntegrationUpdates(runId, plainRun.robotMetaId);
+
+    try { serverIo.of(plainRun.browserId).emit('run-aborted', { runId, robotName, status: 'aborted', finishedAt: new Date().toLocaleString() }); } catch (_) {}
+
+    try {
+      await new Promise(resolve => setTimeout(resolve, 500));
+      await destroyRemoteBrowser(plainRun.browserId, userId);
+    } catch (cleanupError) {
+      logger.log('warn', `Failed to clean up browser for aborted run ${runId}: ${cleanupError}`);
+    }
+  } catch (error) {
+    const errorMessage = error instanceof Error ? error.message : String(error);
+    logger.log('error', `Failed to abort run ${runId}: ${errorMessage}`);
+    throw error;
+  }
+}
+
+const taskList: TaskList = {
+  [QUEUE_NAMES.INITIALIZE_BROWSER_RECORDING]: async (payload: unknown) => {
+    const data = payload as InitializeBrowserData;
+    logger.log('info', `Starting browser initialization job for user: ${data.userId}`);
+    initializeRemoteBrowserForRecording(data.userId);
+    logger.log('info', `Browser initialization triggered for user: ${data.userId}`);
+  },
+
+  [QUEUE_NAMES.DESTROY_BROWSER]: async (payload: unknown) => {
+    const data = payload as DestroyBrowserData;
+    logger.log('info', `Starting browser destruction job for browser: ${data.browserId}`);
+    await destroyRemoteBrowser(data.browserId, data.userId);
+    logger.log('info', `Browser ${data.browserId} destroyed`);
+  },
+
+  [QUEUE_NAMES.INTERPRET_WORKFLOW]: async (payload: unknown) => {
+    const data = payload as InterpretWorkflow;
+    logger.log('info', 'Starting workflow interpretation job');
+    await interpretWholeWorkflow(data.userId);
+    logger.log('info', 'Workflow interpretation job completed');
+  },
+
+  [QUEUE_NAMES.STOP_INTERPRETATION]: async (payload: unknown) => {
+    const data = payload as StopInterpretWorkflow;
+    logger.log('info', 'Starting stop interpretation job');
+    await stopRunningInterpretation(data.userId);
+    logger.log('info', 'Stop interpretation job completed');
+  },
+
+  [QUEUE_NAMES.EXECUTE_RUN]: async (payload: unknown) => {
+    await processRunExecution(payload as ExecuteRunData);
+  },
+
+  [QUEUE_NAMES.ABORT_RUN]: async (payload: unknown) => {
+    const data = payload as AbortRunData;
+    logger.log('info', `Processing abort request for run ${data.runId} by user ${data.userId}`);
+    await abortRun(data.runId, data.userId);
+  },
+
+  [QUEUE_NAMES.SCHEDULED_WORKFLOW]: async (payload: unknown) => {
+    const data = payload as ScheduledWorkflowData;
+    logger.log('info', `Processing scheduled workflow for robot ${data.robotMetaId}`);
+    await handleRunRecording(data.robotMetaId, data.userId);
+  },
+};
+
+let runner: Runner | null = null;
+let runnerPool: Pool | null = null;
+let workersStarted = false;
+
+export async function startWorkers(): Promise<void> {
+  if (workersStarted) {
+    logger.log('warn', 'Graphile Worker runner already started, skipping...');
+    return;
+  }
+
+  try {
+    logger.log('info', 'Starting Graphile Worker runner...');
+
+    runnerPool = new Pool({
+      connectionString,
+      max: TOTAL_CONCURRENCY + 2,
+      ssl: useSSL ? true : undefined,
+    });
+
+    runner = await run({
+      pgPool: runnerPool,
+      concurrency: TOTAL_CONCURRENCY,
+      noHandleSignals: true,
+      taskList,
+    });
+
+    runner.events.on('job:error', ({ job, error }: { job: any; error: unknown }) => {
+      const msg = error instanceof Error ? error.message : String(error);
+      logger.log('error', `Job error for job ${job?.id} (${job?.task_identifier}): ${msg}`);
+    });
+
+    workersStarted = true;
+    logger.log('info', `Graphile Worker runner started (concurrency: ${TOTAL_CONCURRENCY})`);
+  } catch (error: unknown) {
+    const errorMessage = error instanceof Error ? error.message : String(error);
+    logger.log('error', `Failed to start Graphile Worker runner: ${errorMessage}`);
+    throw error;
+  }
+}
+
+export async function stopWorkers(): Promise<void> {
+  if (!workersStarted || !runner) return;
+
+  try {
+    await runner.stop();
+    runner = null;
+  } catch (error: any) {
+    logger.log('warn', `Error stopping Graphile Worker runner: ${error.message}`);
+  }
+
+  try {
+    if (runnerPool) {
+      await runnerPool.end();
+      runnerPool = null;
+    }
+  } catch (error: any) {
+    logger.log('warn', `Error closing runner pool: ${error.message}`);
+  }
+
+  workersStarted = false;
+  logger.log('info', 'Graphile Worker runner stopped');
+}