From 70f654f251a6c13f4fd350586e9fd57efba04cd1 Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Thu, 3 Sep 2026 14:39:03 -0600
Subject: [PATCH 1/6] Add Flowlord rerun actions that deep-link to backload
 with workflow-scoped phase lookup.

---
 apps/flowlord/handler.go                   |   7 +-
 apps/flowlord/handler/backload.tmpl        |   5 +
 apps/flowlord/handler/static/backload.js   | 434 +++++++++++++--------
 apps/flowlord/handler/static/style.css     | 129 +++++-
 apps/flowlord/handler/static/table-sort.js |   8 +-
 apps/flowlord/handler/static/task.js       |   5 +-
 apps/flowlord/handler/static/utils.js      |  82 +++-
 apps/flowlord/handler/task.tmpl            |  11 +-
 apps/flowlord/handler/workflow.tmpl        |  32 +-
 apps/flowlord/handler_test.go              |  13 +
 apps/flowlord/sqlite/workflow.go           |  34 ++
 apps/flowlord/sqlite/workflow_test.go      |  44 +++
 apps/flowlord/test/seed_dev.sql            |  77 ++++
 13 files changed, 703 insertions(+), 178 deletions(-)
 create mode 100644 apps/flowlord/test/seed_dev.sql

diff --git a/apps/flowlord/handler.go b/apps/flowlord/handler.go
index eeb126b..141b309 100644
--- a/apps/flowlord/handler.go
+++ b/apps/flowlord/handler.go
@@ -945,7 +945,12 @@ func (tm *taskMaster) backload(req request) response {
 		end = at
 	}
 
-	phase := tm.taskCache.Search(req.Task, req.Job)
+	var phase sqlite.PhaseDB
+	if req.Workflow != "" {
+		phase = tm.taskCache.GetPhase(req.Workflow, req.Task, req.Job)
+	} else {
+		phase = tm.taskCache.Search(req.Task, req.Job)
+	}
 	if phase.FilePath != "" {
 		msg = append(msg, "phase found in "+phase.FilePath)
 		req.Template = phase.Template
diff --git a/apps/flowlord/handler/backload.tmpl b/apps/flowlord/handler/backload.tmpl
index 98b289a..e14fba3 100644
--- a/apps/flowlord/handler/backload.tmpl
+++ b/apps/flowlord/handler/backload.tmpl
@@ -107,6 +107,10 @@
                 <div class="info-card template-section" id="templateSection" style="display: none;">
                     <h3>Template Details</h3>
                     <div class="template-info">
+                        <div class="form-group">
+                            <label>Workflow</label>
+                            <div class="template-display" id="workflowDisplay"></div>
+                        </div>
                         <div class="form-group">
                             <label>Template</label>
                             <div class="template-display" id="templateDisplay"></div>
@@ -146,6 +150,7 @@
                             <thead>
                                 <tr>
                                     <th class="num-column">#</th>
+                                    <th class="id-column" id="previewIdHeader" style="display: none;">ID</th>
                                     <th class="type-column">Type</th>
                                     <th class="job-column">Job</th>
                                     <th class="info-column">Info</th>
diff --git a/apps/flowlord/handler/static/backload.js b/apps/flowlord/handler/static/backload.js
index b6f2d8f..ce0fbb5 100644
--- a/apps/flowlord/handler/static/backload.js
+++ b/apps/flowlord/handler/static/backload.js
@@ -5,13 +5,14 @@
     // Module state
     let allPhases = [];
     let currentPhase = null;
+    let selectedWorkflow = '';
     let previewTasks = [];
     let searchTimeout = null;
     let selectedDropdownIndex = -1;
 
     // DOM element references (cached on init)
     const elements = {};
-    
+
     // DateTime picker instances
     let pickers = {
         at: null,
@@ -19,10 +20,57 @@
         to: null
     };
 
+    function taskPageBase() {
+        return window.location.pathname.includes('_preview') ? './task_preview.html' : '/web/task';
+    }
+
+    function findPhase(task, job, workflow) {
+        return allPhases.find(p =>
+            p.task === task &&
+            (p.job === job || (!job && !p.job)) &&
+            (!workflow || p.workflow === workflow)
+        );
+    }
+
+    function setSelectedWorkflow(workflow) {
+        selectedWorkflow = workflow || '';
+    }
+
+    function parseMetaString(metaStr) {
+        if (window.FlowlordUtils && window.FlowlordUtils.parseMetaString) {
+            return window.FlowlordUtils.parseMetaString(metaStr);
+        }
+        const out = {};
+        if (!metaStr) return out;
+        metaStr.split('&').forEach(pair => {
+            const eq = pair.indexOf('=');
+            if (eq === -1) return;
+            const key = decodeURIComponent(pair.slice(0, eq));
+            const val = decodeURIComponent(pair.slice(eq + 1));
+            if (key) out[key] = val;
+        });
+        return out;
+    }
+
+    function taskCreatedDate(task) {
+        if (task && task.created) {
+            const d = task.created.slice(0, 10);
+            if (/^\d{4}-\d{2}-\d{2}$/.test(d)) return d;
+        }
+        return new Date().toISOString().split('T')[0];
+    }
+
+    function buildViewAllTasksHref(tasks) {
+        const ids = (tasks || []).map(t => t.id).filter(Boolean);
+        if (ids.length === 0) return '';
+        const date = taskCreatedDate(tasks[0]);
+        return taskPageBase() + '?date=' + encodeURIComponent(date) + '&id=' + ids.map(encodeURIComponent).join(',');
+    }
+
     // Initialize the backload form
     function init(phasesData, apiEndpoint) {
         allPhases = phasesData || [];
-        
+
         // Cache DOM elements
         elements.taskSearch = document.getElementById('taskSearch');
         elements.taskDropdown = document.getElementById('taskDropdown');
@@ -30,6 +78,7 @@
         elements.workflowFilter = document.getElementById('workflowFilter');
         elements.jobSelect = document.getElementById('jobSelect');
         elements.templateSection = document.getElementById('templateSection');
+        elements.workflowDisplay = document.getElementById('workflowDisplay');
         elements.templateDisplay = document.getElementById('templateDisplay');
         elements.ruleDisplay = document.getElementById('ruleDisplay');
         elements.metaSection = document.getElementById('metaSection');
@@ -43,6 +92,7 @@
         elements.previewResultsHeading = document.getElementById('previewResultsHeading');
         elements.previewStatus = document.getElementById('previewStatus');
         elements.previewTableBody = document.getElementById('previewTableBody');
+        elements.previewIdHeader = document.getElementById('previewIdHeader');
         elements.previewCount = document.getElementById('previewCount');
         elements.executionSection = document.getElementById('executionSection');
         elements.executionStatus = document.getElementById('executionStatus');
@@ -53,24 +103,19 @@
         elements.singleDateInput = document.getElementById('singleDateInput');
         elements.dateRangeInputs = document.getElementById('dateRangeInputs');
 
-        // Store API endpoint
         elements.apiEndpoint = apiEndpoint || '/backload';
 
-        // Initialize datetime pickers
         initializePickers();
-
-        // Setup event listeners
         setupEventListeners();
 
         if (window.FlowlordUtils && elements.previewTableBody) {
             window.FlowlordUtils.enableCellActions(elements.previewTableBody);
         }
 
-        // Initialize date inputs with today's date
         initializeDates();
+        applyQueryParams();
     }
 
-    // Initialize datetime picker instances
     function initializePickers() {
         if (window.FlowlordDateTimePicker) {
             pickers.at = window.FlowlordDateTimePicker.create('atPicker', {
@@ -85,7 +130,6 @@
         }
     }
 
-    // Get unique tasks from phases
     function getUniqueTasks(workflowFilterValue) {
         const taskSet = new Set();
         allPhases.forEach(p => {
@@ -96,41 +140,27 @@
         return Array.from(taskSet).sort();
     }
 
-    // Setup all event listeners
     function setupEventListeners() {
-        // Date mode toggle
         document.querySelectorAll('.toggle-btn').forEach(btn => {
             btn.addEventListener('click', handleDateModeToggle);
         });
 
-        // Task search
         elements.taskSearch.addEventListener('input', handleTaskSearchInput);
         elements.taskSearch.addEventListener('focus', handleTaskSearchFocus);
         elements.taskSearch.addEventListener('keydown', handleTaskSearchKeydown);
-
-        // Task dropdown
         elements.taskDropdown.addEventListener('click', handleDropdownClick);
-
-        // Close dropdown when clicking outside
         document.addEventListener('click', handleDocumentClick);
-
-        // Workflow filter
         elements.workflowFilter.addEventListener('change', handleWorkflowFilterChange);
-
-        // Job selection
         elements.jobSelect.addEventListener('change', handleJobSelectChange);
-
-        // Buttons
         elements.previewBtn.addEventListener('click', handlePreviewClick);
         elements.executeBtn.addEventListener('click', handleExecuteClick);
         elements.resetBtn.addEventListener('click', handleResetClick);
     }
 
-    // Date mode toggle handler
     function handleDateModeToggle() {
         document.querySelectorAll('.toggle-btn').forEach(b => b.classList.remove('active'));
         this.classList.add('active');
-        
+
         if (this.dataset.mode === 'range') {
             elements.dateRangeInputs.style.display = 'block';
             elements.singleDateInput.style.display = 'none';
@@ -143,17 +173,15 @@
         updatePreviewButton();
     }
 
-    // Task search input handler
     function handleTaskSearchInput() {
         clearTimeout(searchTimeout);
         const query = this.value.trim();
-        
+
         searchTimeout = setTimeout(() => {
             showTaskDropdown(query);
         }, 100);
     }
 
-    // Task search focus handler
     function handleTaskSearchFocus() {
         this.value = '';
         elements.taskSelect.value = '';
@@ -161,12 +189,11 @@
         showTaskDropdown('');
     }
 
-    // Task search keydown handler for keyboard navigation
     function handleTaskSearchKeydown(e) {
         const items = elements.taskDropdown.querySelectorAll('.search-dropdown-item');
         if (items.length === 0) return;
 
-        switch(e.key) {
+        switch (e.key) {
             case 'ArrowDown':
                 e.preventDefault();
                 selectedDropdownIndex = Math.min(selectedDropdownIndex + 1, items.length - 1);
@@ -180,8 +207,7 @@
             case 'Enter':
                 e.preventDefault();
                 if (selectedDropdownIndex >= 0 && items[selectedDropdownIndex]) {
-                    const task = items[selectedDropdownIndex].dataset.task;
-                    selectTask(task);
+                    selectTask(items[selectedDropdownIndex].dataset.task);
                 }
                 break;
             case 'Escape':
@@ -192,7 +218,6 @@
         }
     }
 
-    // Update dropdown selection highlight
     function updateDropdownSelection(items) {
         items.forEach((item, index) => {
             if (index === selectedDropdownIndex) {
@@ -204,36 +229,25 @@
         });
     }
 
-    // Select a task
     function selectTask(task) {
         elements.taskSearch.value = task;
         elements.taskSelect.value = task;
         elements.taskDropdown.style.display = 'none';
         selectedDropdownIndex = -1;
-        
-        // Set workflow filter to the task's workflow if not already filtered
-        if (!elements.workflowFilter.value) {
-            const phase = allPhases.find(p => p.task === task);
-            if (phase && phase.workflow) {
-                elements.workflowFilter.value = phase.workflow;
-            }
-        }
-        
         onTaskSelected(task);
     }
 
-    // Show task dropdown with optional filtering
     function showTaskDropdown(query) {
         const workflow = elements.workflowFilter.value;
         const tasks = getUniqueTasks(workflow);
-        const matches = query 
+        const matches = query
             ? tasks.filter(t => t.toLowerCase().includes(query.toLowerCase()))
             : tasks;
-        
+
         selectedDropdownIndex = -1;
-        
+
         if (matches.length > 0) {
-            elements.taskDropdown.innerHTML = matches.map(task => 
+            elements.taskDropdown.innerHTML = matches.map(task =>
                 `<div class="search-dropdown-item" data-task="${window.FlowlordUtils.escapeHtml(task)}">${query ? highlightMatch(task, query) : window.FlowlordUtils.escapeHtml(task)}</div>`
             ).join('');
             elements.taskDropdown.style.display = 'block';
@@ -243,23 +257,19 @@
         }
     }
 
-    // Highlight matching text in search results
     function highlightMatch(text, query) {
         const idx = text.toLowerCase().indexOf(query.toLowerCase());
         if (idx === -1) return window.FlowlordUtils.escapeHtml(text);
         return window.FlowlordUtils.escapeHtml(text.slice(0, idx)) + '<strong>' + window.FlowlordUtils.escapeHtml(text.slice(idx, idx + query.length)) + '</strong>' + window.FlowlordUtils.escapeHtml(text.slice(idx + query.length));
     }
 
-    // Handle dropdown item click
     function handleDropdownClick(e) {
         const item = e.target.closest('.search-dropdown-item');
         if (item) {
-            const task = item.dataset.task;
-            selectTask(task);
+            selectTask(item.dataset.task);
         }
     }
 
-    // Close dropdown when clicking outside
     function handleDocumentClick(e) {
         if (!elements.taskSearch.contains(e.target) && !elements.taskDropdown.contains(e.target)) {
             elements.taskDropdown.style.display = 'none';
@@ -267,78 +277,111 @@
         }
     }
 
-    // Workflow filter change handler
     function handleWorkflowFilterChange() {
         elements.taskSearch.value = '';
         elements.taskSelect.value = '';
         elements.jobSelect.innerHTML = '<option value="">Select a job...</option>';
         elements.jobSelect.disabled = true;
+        setSelectedWorkflow('');
         hideTemplateInfo();
         updatePreviewButton();
     }
 
-    // Handle task selection
+    function populateJobOptions(phases) {
+        elements.jobSelect.innerHTML = '<option value="">Select a job...</option>';
+        const withJobs = phases.filter(p => p.job);
+        if (withJobs.length === 0) {
+            elements.jobSelect.disabled = true;
+            return false;
+        }
+
+        const jobNames = [...new Set(withJobs.map(p => p.job))].sort();
+        jobNames.forEach(job => {
+            const jobPhases = withJobs.filter(p => p.job === job);
+            const showWorkflowInLabel = jobPhases.length > 1;
+            jobPhases.forEach(phase => {
+                const option = document.createElement('option');
+                option.value = job;
+                option.dataset.workflow = phase.workflow || '';
+                if (showWorkflowInLabel && phase.workflow) {
+                    option.textContent = job + ' (' + phase.workflow + ')';
+                } else {
+                    option.textContent = job;
+                }
+                elements.jobSelect.appendChild(option);
+            });
+        });
+        elements.jobSelect.disabled = false;
+        return true;
+    }
+
     function onTaskSelected(task) {
         const workflow = elements.workflowFilter.value;
         elements.jobSelect.innerHTML = '<option value="">Select a job...</option>';
         elements.jobSelect.disabled = true;
         hideTemplateInfo();
-        
-        // Find phases matching this task (optionally filtered by workflow)
-        const phases = allPhases.filter(p => 
+        setSelectedWorkflow('');
+
+        const phases = allPhases.filter(p =>
             p.task === task && (!workflow || p.workflow === workflow)
         );
-        const jobs = [...new Set(phases.map(p => p.job).filter(j => j))];
-        
-        if (jobs.length > 0) {
-            jobs.sort().forEach(job => {
-                const option = document.createElement('option');
-                option.value = job;
-                option.textContent = job;
-                elements.jobSelect.appendChild(option);
-            });
-            elements.jobSelect.disabled = false;
-        } else {
-            // No job needed, use first phase
-            const phase = phases[0];
-            if (phase) {
-                showTemplateInfo(phase);
-            }
+
+        if (populateJobOptions(phases)) {
+            updatePreviewButton();
+            return;
+        }
+
+        const phase = phases[0];
+        if (phase) {
+            setSelectedWorkflow(phase.workflow || '');
+            showTemplateInfo(phase);
         }
         updatePreviewButton();
     }
 
-    // Job selection change handler
     function handleJobSelectChange() {
         const task = elements.taskSelect.value;
         const job = this.value;
-        const workflow = elements.workflowFilter.value;
-        
-        const phase = allPhases.find(p => 
-            p.task === task && 
-            (p.job === job || (!job && !p.job)) &&
-            (!workflow || p.workflow === workflow)
-        );
+        const selectedOption = this.options[this.selectedIndex];
+        const optionWorkflow = selectedOption && selectedOption.dataset ? selectedOption.dataset.workflow : '';
+        const workflow = optionWorkflow || elements.workflowFilter.value;
+
+        setSelectedWorkflow(workflow);
+
+        const phase = findPhase(task, job, workflow);
         if (phase) {
             showTemplateInfo(phase);
         }
         updatePreviewButton();
     }
 
-    // Format rule string for better readability
+    function selectJobOption(job, workflow) {
+        if (!job) return;
+        for (let i = 0; i < elements.jobSelect.options.length; i++) {
+            const opt = elements.jobSelect.options[i];
+            if (opt.value !== job) continue;
+            if (workflow && opt.dataset.workflow && opt.dataset.workflow !== workflow) continue;
+            elements.jobSelect.selectedIndex = i;
+            handleJobSelectChange.call(elements.jobSelect);
+            return;
+        }
+    }
+
     function formatRule(str) {
         if (!str) return '(no rule)';
         return str.split('&').join('\n');
     }
 
-    // Show template information and detect meta fields
     function showTemplateInfo(phase) {
         currentPhase = phase;
+        setSelectedWorkflow(phase.workflow || selectedWorkflow);
         elements.templateSection.style.display = 'block';
+        if (elements.workflowDisplay) {
+            elements.workflowDisplay.textContent = phase.workflow || '(unknown workflow)';
+        }
         elements.templateDisplay.textContent = phase.template || '(no template)';
         elements.ruleDisplay.textContent = formatRule(phase.rule);
-        
-        // Parse template for meta fields
+
         const metaRegex = /\{meta:(\w+)\}/g;
         const metaKeys = [];
         let match;
@@ -347,15 +390,13 @@
                 metaKeys.push(match[1]);
             }
         }
-        
-        // Check if rule has meta-file
+
         const hasMetaFile = phase.rule && phase.rule.includes('meta-file=');
-        
-        // Show meta fields section if template has meta placeholders and no meta-file in rule
+
         if (metaKeys.length > 0 && !hasMetaFile) {
             elements.metaSection.style.display = 'block';
             elements.metaFieldsContainer.innerHTML = '';
-            
+
             metaKeys.forEach(key => {
                 const formGroup = document.createElement('div');
                 formGroup.className = 'form-group';
@@ -370,8 +411,7 @@
         } else {
             elements.metaSection.style.display = 'none';
         }
-        
-        // Show meta file section if rule has meta-file
+
         if (hasMetaFile) {
             elements.metaFileSection.style.display = 'block';
             const metaFileMatch = phase.rule.match(/meta-file=([^&]+)/);
@@ -384,9 +424,9 @@
         }
     }
 
-    // Hide template information
     function hideTemplateInfo() {
         currentPhase = null;
+        setSelectedWorkflow('');
         elements.templateSection.style.display = 'none';
         elements.metaSection.style.display = 'none';
         elements.metaFileSection.style.display = 'none';
@@ -394,23 +434,20 @@
         elements.executionSection.style.display = 'none';
         elements.executeBtn.style.display = 'none';
         elements.requestBodySection.style.display = 'none';
-        
         elements.metaFieldsContainer.innerHTML = '';
         elements.metaFileInput.value = '';
     }
 
-    // Get current date mode from toggle
     function getDateMode() {
         const activeBtn = document.querySelector('.toggle-btn.active');
-        return activeBtn ? activeBtn.dataset.mode : 'range';
+        return activeBtn ? activeBtn.dataset.mode : 'single';
     }
 
-    // Update preview button state
     function updatePreviewButton() {
         const task = elements.taskSelect.value;
         const dateMode = getDateMode();
         let hasDate = false;
-        
+
         if (dateMode === 'range') {
             const fromValue = pickers.from ? pickers.from.getValue() : null;
             const toValue = pickers.to ? pickers.to.getValue() : null;
@@ -419,31 +456,34 @@
             const atValue = pickers.at ? pickers.at.getValue() : null;
             hasDate = atValue && atValue.date;
         }
-        
+
         elements.previewBtn.disabled = !task || !hasDate;
     }
 
-    // Build request object
     function buildRequest(execute) {
         const dateMode = getDateMode();
         const request = {
             Task: elements.taskSelect.value,
         };
-        
+
         if (execute) {
             request.Execute = true;
         }
-        
+
         const job = elements.jobSelect.value;
         if (job) {
             request.Job = job;
         }
-        
+
+        if (selectedWorkflow) {
+            request.Workflow = selectedWorkflow;
+        }
+
         const by = elements.bySelect.value;
         if (by && by !== 'day') {
             request.By = by;
         }
-        
+
         if (dateMode === 'range') {
             if (pickers.from) {
                 const fromValue = pickers.from.getValue();
@@ -457,16 +497,13 @@
                     request.To = toValue.formatted;
                 }
             }
-        } else {
-            if (pickers.at) {
-                const atValue = pickers.at.getValue();
-                if (atValue.date) {
-                    request.At = atValue.formatted;
-                }
+        } else if (pickers.at) {
+            const atValue = pickers.at.getValue();
+            if (atValue.date) {
+                request.At = atValue.formatted;
             }
         }
-        
-        // Collect meta fields
+
         if (elements.metaSection.style.display !== 'none') {
             const metaInputs = document.querySelectorAll('.meta-input');
             if (metaInputs.length > 0) {
@@ -483,19 +520,17 @@
                 }
             }
         }
-        
-        // Collect meta file
+
         if (elements.metaFileSection.style.display !== 'none') {
             const metaFile = elements.metaFileInput.value.trim();
             if (metaFile) {
                 request['meta-file'] = metaFile;
             }
         }
-        
+
         return request;
     }
 
-    // Set button loading state
     function setButtonLoading(btn, loading, originalText) {
         if (loading) {
             btn.disabled = true;
@@ -508,39 +543,35 @@
         }
     }
 
-    // Preview button click handler
     async function handlePreviewClick() {
         const request = buildRequest(false);
-        const requestBody = JSON.stringify(request, null, 2);
-        
         elements.requestBodySection.style.display = 'block';
-        elements.requestBodyDisplay.textContent = requestBody;
-        
+        elements.requestBodyDisplay.textContent = JSON.stringify(request, null, 2);
+
         setButtonLoading(elements.previewBtn, true, 'Preview (Dry Run)');
-        
+
         try {
             const response = await fetch(elements.apiEndpoint, {
                 method: 'POST',
                 headers: { 'Content-Type': 'application/json' },
                 body: JSON.stringify(request),
             });
-            
+
             const responseText = await response.text();
             let data;
-            
+
             try {
                 data = JSON.parse(responseText);
             } catch (e) {
                 throw new Error(responseText || 'Request failed');
             }
-            
+
             if (!response.ok) {
                 throw new Error(data.Status || responseText || 'Request failed');
             }
-            
+
             previewTasks = data.Tasks || [];
             showPreviewResults(data);
-            
         } catch (error) {
             elements.previewStatus.className = 'preview-status error';
             elements.previewStatus.textContent = 'Error: ' + error.message;
@@ -554,7 +585,6 @@
         }
     }
 
-    // Parse API error body: JSON Status or raw text
     function messageFromApiResponse(responseText, fallback) {
         if (responseText == null || responseText === '') {
             return fallback || 'Request failed';
@@ -568,20 +598,19 @@
         return responseText;
     }
 
-    // Execute button click handler
     async function handleExecuteClick() {
         const request = buildRequest(true);
         elements.requestBodyDisplay.textContent = JSON.stringify(request, null, 2);
-        
+
         setButtonLoading(elements.executeBtn, true, 'Execute Backload');
-        
+
         try {
             const response = await fetch(elements.apiEndpoint, {
                 method: 'POST',
                 headers: { 'Content-Type': 'application/json' },
                 body: JSON.stringify(request),
             });
-            
+
             const responseText = await response.text();
             let data = null;
             try {
@@ -589,26 +618,24 @@
             } catch (e) {
                 data = null;
             }
-            
+
             if (!response.ok) {
-                const msg = messageFromApiResponse(responseText, 'Execution failed');
                 elements.executionSection.style.display = 'block';
                 elements.executionStatus.className = 'execution-status error';
-                elements.executionStatus.textContent = msg;
+                elements.executionStatus.textContent = messageFromApiResponse(responseText, 'Execution failed');
                 return;
             }
-            
+
             if (!data) {
                 elements.executionSection.style.display = 'block';
                 elements.executionStatus.className = 'execution-status error';
                 elements.executionStatus.textContent = responseText || 'Invalid JSON response';
                 return;
             }
-            
+
             showExecutionResults(data);
             elements.executionSection.style.display = 'none';
             elements.executeBtn.style.display = 'none';
-            
         } catch (error) {
             elements.executionSection.style.display = 'block';
             elements.executionStatus.className = 'execution-status error';
@@ -618,7 +645,6 @@
         }
     }
 
-    // Reset button click handler
     function handleResetClick() {
         elements.taskSearch.value = '';
         elements.taskSelect.value = '';
@@ -626,18 +652,18 @@
         elements.jobSelect.innerHTML = '<option value="">Select a job...</option>';
         elements.jobSelect.disabled = true;
         elements.bySelect.value = 'day';
-        
-        // Reset pickers
+        setSelectedWorkflow('');
+
         if (pickers.at) pickers.at.setValue('', '');
         if (pickers.from) pickers.from.setValue('', '');
         if (pickers.to) pickers.to.setValue('', '');
-        
+
         document.querySelectorAll('.toggle-btn').forEach(b => b.classList.remove('active'));
         document.querySelector('.toggle-btn[data-mode="single"]').classList.add('active');
         elements.singleDateInput.style.display = 'block';
         elements.dateRangeInputs.style.display = 'none';
         elements.bySelectContainer.style.display = 'none';
-        
+
         hideTemplateInfo();
         initializeDates();
         if (elements.previewResultsHeading) {
@@ -646,13 +672,26 @@
         updatePreviewButton();
     }
 
-    function renderTasksIntoPreviewTable(tasks, emptyRowHtml) {
+    function renderTasksIntoPreviewTable(tasks, emptyRowHtml, options) {
+        options = options || {};
+        const showIds = !!options.showIds;
+        const colCount = showIds ? 6 : 5;
+
         elements.previewTableBody.innerHTML = '';
         if (tasks && tasks.length > 0) {
             tasks.forEach((task, index) => {
                 const row = document.createElement('tr');
+                let idCell = '';
+                if (showIds && task.id) {
+                    const date = taskCreatedDate(task);
+                    const href = taskPageBase() + '?date=' + encodeURIComponent(date) + '&id=' + encodeURIComponent(task.id);
+                    idCell = `<td class="id-cell id-column"><a class="task-id-link" href="${window.FlowlordUtils.escapeAttr(href)}">${window.FlowlordUtils.escapeHtml(task.id)}</a></td>`;
+                } else if (showIds) {
+                    idCell = '<td class="id-cell id-column"></td>';
+                }
                 row.innerHTML = `
                     <td class="num-cell num-column">${index + 1}</td>
+                    ${idCell}
                     <td class="type-cell type-column copyable" title="Click for actions">${window.FlowlordUtils.escapeHtml(task.type || '')}</td>
                     <td class="job-cell job-column copyable" title="Click for actions">${window.FlowlordUtils.escapeHtml(task.job || '')}</td>
                     <td class="info-cell info-column expandable copyable" title="Click for actions">${window.FlowlordUtils.escapeHtml(task.info || '')}</td>
@@ -660,22 +699,31 @@
                 `;
                 elements.previewTableBody.appendChild(row);
             });
+            if (window.FlowlordUtils) {
+                window.FlowlordUtils.enableCellActions(elements.previewTableBody);
+            }
         } else {
-            elements.previewTableBody.innerHTML = emptyRowHtml || '<tr><td colspan="5" class="no-tasks">No tasks</td></tr>';
+            elements.previewTableBody.innerHTML = emptyRowHtml || `<tr><td colspan="${colCount}" class="no-tasks">No tasks</td></tr>`;
+        }
+    }
+
+    function setPreviewIdColumnVisible(visible) {
+        if (elements.previewIdHeader) {
+            elements.previewIdHeader.style.display = visible ? '' : 'none';
         }
     }
 
-    // Show preview results
     function showPreviewResults(data) {
         if (elements.previewResultsHeading) {
             elements.previewResultsHeading.textContent = 'Preview Results';
         }
+        setPreviewIdColumnVisible(false);
         elements.previewSection.style.display = 'block';
         elements.previewStatus.className = 'preview-status info';
         elements.previewStatus.textContent = data.Status || 'Dry run complete';
-        
+
         renderTasksIntoPreviewTable(data.Tasks, '<tr><td colspan="5" class="no-tasks">No tasks would be created</td></tr>');
-        
+
         if (data.Tasks && data.Tasks.length > 0) {
             elements.previewCount.textContent = `Total tasks to be created: ${data.Count}`;
             elements.executeBtn.style.display = 'inline-block';
@@ -690,30 +738,104 @@
         if (elements.previewResultsHeading) {
             elements.previewResultsHeading.textContent = 'Execution results';
         }
+        setPreviewIdColumnVisible(true);
         elements.previewSection.style.display = 'block';
         elements.previewStatus.className = 'preview-status execution-success';
         elements.previewStatus.innerHTML =
             '<strong>Executed (not a dry run)</strong><br>' +
             window.FlowlordUtils.escapeHtml(data.Status || '');
-        renderTasksIntoPreviewTable(data.Tasks, '<tr><td colspan="5" class="no-tasks">No tasks were sent</td></tr>');
+
+        renderTasksIntoPreviewTable(
+            data.Tasks,
+            '<tr><td colspan="6" class="no-tasks">No tasks were sent</td></tr>',
+            { showIds: true }
+        );
+
         const n = typeof data.Count === 'number' ? data.Count : (data.Tasks && data.Tasks.length) || 0;
-        elements.previewCount.textContent = `Created ${n} task(s). Jobs were sent to the task bus.`;
+        const viewAllHref = buildViewAllTasksHref(data.Tasks);
+        let countHtml = `Created ${n} task(s). Jobs were sent to the task bus.`;
+        if (viewAllHref && n > 0) {
+            countHtml += ` <a class="task-id-link" href="${window.FlowlordUtils.escapeAttr(viewAllHref)}">View all ${n} created tasks</a>`;
+        }
+        elements.previewCount.innerHTML = countHtml;
     }
 
-    // Initialize date inputs with today's date
     function initializeDates() {
         const today = new Date().toISOString().split('T')[0];
-        
-        // Initialize pickers with today's date
         if (pickers.at) pickers.at.setValue(today, '');
         if (pickers.from) pickers.from.setValue(today, '');
         if (pickers.to) pickers.to.setValue(today, '');
-        
         updatePreviewButton();
     }
 
-    // Export to global scope
+    function setMetaFieldValue(key, value) {
+        const input = document.querySelector('.meta-input[data-meta-key="' + key + '"]');
+        if (input) {
+            input.value = value;
+        }
+    }
+
+    function applyQueryParams() {
+        const params = new URLSearchParams(window.location.search);
+        const task = params.get('task');
+        if (!task) return;
+
+        const workflow = params.get('workflow') || '';
+        const job = params.get('job') || '';
+        const at = params.get('at') || '';
+
+        if (workflow) {
+            elements.workflowFilter.value = workflow;
+        }
+
+        selectTask(task);
+
+        if (job) {
+            selectJobOption(job, workflow);
+        } else if (workflow) {
+            const phase = findPhase(task, '', workflow);
+            if (phase) {
+                setSelectedWorkflow(workflow);
+                showTemplateInfo(phase);
+            }
+        }
+
+        if (at && pickers.at) {
+            document.querySelectorAll('.toggle-btn').forEach(b => b.classList.remove('active'));
+            const singleBtn = document.querySelector('.toggle-btn[data-mode="single"]');
+            if (singleBtn) singleBtn.classList.add('active');
+            elements.dateRangeInputs.style.display = 'none';
+            elements.singleDateInput.style.display = 'block';
+            elements.bySelectContainer.style.display = 'none';
+            pickers.at.setValue(at, '');
+        }
+
+        params.forEach((value, key) => {
+            if (key.startsWith('meta.')) {
+                setMetaFieldValue(key.slice(5), value);
+            }
+        });
+
+        updatePreviewButton();
+
+        if (params.get('preview') === '1') {
+            setTimeout(function() {
+                if (!elements.previewBtn.disabled) {
+                    handlePreviewClick();
+                }
+            }, 0);
+        }
+    }
+
+    function buildBackloadUrl(taskRow) {
+        if (window.FlowlordUtils && window.FlowlordUtils.buildBackloadUrl) {
+            return window.FlowlordUtils.buildBackloadUrl(taskRow);
+        }
+        return '/web/backload';
+    }
+
     window.FlowlordBackload = {
-        init: init
+        init: init,
+        buildBackloadUrl: buildBackloadUrl
     };
 })();
diff --git a/apps/flowlord/handler/static/style.css b/apps/flowlord/handler/static/style.css
index 2848a2a..5492625 100644
--- a/apps/flowlord/handler/static/style.css
+++ b/apps/flowlord/handler/static/style.css
@@ -958,10 +958,13 @@ th.job-column, td.job-column {
     max-width: 80px;
 }
 
-/* Message column - takes remaining space with generous width */
+/* Message column - flexible width within viewport */
 th.message-column, td.message-column {
     width: auto;
-    min-width: 400px;
+    min-width: 0;
+    max-width: none;
+    word-break: break-word;
+    overflow-wrap: break-word;
 }
 
 /* Result/Status column - compact for status */
@@ -1063,22 +1066,35 @@ th.status-cell, td.status-cell {
 #workflowTable {
     table-layout: fixed;
     width: 100%;
+    max-width: 100%;
+}
+
+#taskTable {
+    table-layout: fixed;
+    width: 100%;
+    max-width: 100%;
+}
+
+.table-container:has(#taskTable),
+.table-container:has(#workflowTable) {
+    overflow-x: hidden;
+    max-width: 100%;
+    width: 100%;
 }
 
 #workflowTable th,
 #workflowTable td {
     padding: 12px 8px;
     vertical-align: top;
+    word-break: break-word;
+    overflow-wrap: break-word;
 }
 
-/* Ensure workflow table doesn't overflow horizontally */
-.table-container {
-    overflow-x: auto;
-    max-width: 100%;
-    width: 100%;
+#taskTable th,
+#taskTable td {
+    word-break: break-word;
+    overflow-wrap: break-word;
 }
-
-/* Better responsive handling for workflow table */
 @media (max-width: 1200px) {
     th.rule-column, td.rule-column,
     th.template-column, td.template-column {
@@ -1745,6 +1761,101 @@ th.status-cell, td.status-cell {
     line-height: 0;
 }
 
+th.row-action-col,
+td.row-action-col {
+    border: none;
+    background: transparent;
+    padding: 4px 2px;
+    width: 32px;
+    min-width: 32px;
+    max-width: 32px;
+    white-space: nowrap;
+    vertical-align: middle;
+    text-align: center;
+    cursor: default;
+}
+
+th.row-action-col:hover {
+    background: transparent;
+}
+
+.row-action-btn {
+    display: inline-flex;
+    align-items: center;
+    justify-content: center;
+    width: 28px;
+    height: 28px;
+    padding: 0;
+    border: none;
+    border-radius: 4px;
+    background: transparent;
+    cursor: pointer;
+    line-height: 0;
+}
+
+.row-action-icon {
+    display: block;
+    flex-shrink: 0;
+    width: 16px;
+    height: 16px;
+}
+
+.row-action-replay .row-action-icon,
+.row-action-play .row-action-icon {
+    width: 17px;
+    height: 17px;
+}
+
+#workflowTable th.workflow-file-cell,
+#workflowTable td.workflow-file-cell,
+#workflowTable th.task-cell,
+#workflowTable td.task-cell,
+#workflowTable th.job-cell,
+#workflowTable td.job-cell,
+#workflowTable th.rule-cell,
+#workflowTable td.rule-cell,
+#workflowTable th.depends-on-cell,
+#workflowTable td.depends-on-cell,
+#workflowTable th.retry-cell,
+#workflowTable td.retry-cell,
+#workflowTable th.template-cell,
+#workflowTable td.template-cell,
+#workflowTable th.status-cell,
+#workflowTable td.status-cell {
+    width: auto;
+    max-width: none;
+}
+
+#workflowTable th.row-action-col,
+#workflowTable td.row-action-col {
+    width: 21px;
+    padding: 4px 0;
+    vertical-align: middle;
+    overflow: hidden;
+}
+
+#workflowTable .row-action-btn {
+    width: 19px;
+    height: 19px;
+    min-width: 19px;
+}
+
+.row-action-replay {
+    color: #6f42c1;
+}
+
+.row-action-replay:hover {
+    background-color: #f3ebff;
+}
+
+.row-action-play {
+    color: #198754;
+}
+
+.row-action-play:hover {
+    background-color: #e8f5ee;
+}
+
 /* ===== COPY FEEDBACK STYLES ===== */
 .copy-feedback {
     position: fixed;
diff --git a/apps/flowlord/handler/static/table-sort.js b/apps/flowlord/handler/static/table-sort.js
index 1295bea..7ab8742 100644
--- a/apps/flowlord/handler/static/table-sort.js
+++ b/apps/flowlord/handler/static/table-sort.js
@@ -55,9 +55,11 @@
         // Perform the sort
         function sortTable(column, direction) {
             const rows = Array.from(tbody.querySelectorAll('tr'));
-            const columnIndex = Array.from(headers).findIndex(th => th.dataset.sort === column);
-            
-            if (columnIndex === -1) return;
+            const header = Array.from(headers).find(th => th.dataset.sort === column);
+
+            if (!header) return;
+
+            const columnIndex = header.cellIndex;
 
             const columnType = columnTypes[column] || 'string';
 
diff --git a/apps/flowlord/handler/static/task.js b/apps/flowlord/handler/static/task.js
index 88b4491..ef4ed9d 100644
--- a/apps/flowlord/handler/static/task.js
+++ b/apps/flowlord/handler/static/task.js
@@ -506,7 +506,10 @@
 
         if (tbody) {
             if (window.FlowlordUtils) {
-                window.FlowlordUtils.enableCellActions(tbody, { onFilter: applyFilter });
+                window.FlowlordUtils.enableCellActions(tbody, {
+                    onFilter: applyFilter
+                });
+                window.FlowlordUtils.enableRowBackloadActions(tbody, window.FlowlordUtils.taskRowDataFromRow);
             }
         }
 
diff --git a/apps/flowlord/handler/static/utils.js b/apps/flowlord/handler/static/utils.js
index 6883dd5..e9ee429 100644
--- a/apps/flowlord/handler/static/utils.js
+++ b/apps/flowlord/handler/static/utils.js
@@ -198,6 +198,79 @@
         '<path fill="currentColor" fill-rule="evenodd" d="M4 2a2 2 0 0 1 2-2h8a2 2 0 0 1 2 2v8a2 2 0 0 1-2 2H6a2 2 0 0 1-2-2V2zm2-1a1 1 0 0 0-1 1v8a1 1 0 0 0 1 1h8a1 1 0 0 0 1-1V2a1 1 0 0 0-1-1H6zM2 5a1 1 0 0 0-1 1v8a1 1 0 0 0 1 1h8a1 1 0 0 0 1-1v-1h1v1a2 2 0 0 1-2 2H2a2 2 0 0 1-2-2V6a2 2 0 0 1 2-2h1v1H2z"/>' +
         '</svg>';
 
+    function parseMetaString(metaStr) {
+        const out = {};
+        if (!metaStr) return out;
+        metaStr.split('&').forEach(pair => {
+            const eq = pair.indexOf('=');
+            if (eq === -1) return;
+            const key = decodeURIComponent(pair.slice(0, eq));
+            const val = decodeURIComponent(pair.slice(eq + 1));
+            if (key) out[key] = val;
+        });
+        return out;
+    }
+
+    function buildBackloadUrl(taskRow) {
+        const params = new URLSearchParams();
+        if (taskRow.type) params.set('task', taskRow.type);
+        if (taskRow.job) params.set('job', taskRow.job);
+
+        const meta = parseMetaString(taskRow.meta || '');
+        const workflow = taskRow.workflow || meta.workflow;
+        if (workflow) params.set('workflow', workflow);
+        if (meta.cron) params.set('at', meta.cron);
+
+        const skip = { cron: true, workflow: true, job: true };
+        Object.keys(meta).forEach(k => {
+            if (!skip[k]) params.set('meta.' + k, meta[k]);
+        });
+
+        params.set('preview', '1');
+
+        const base = window.location.pathname.includes('_preview') ? './backload_preview.html' : '/web/backload';
+        return base + '?' + params.toString();
+    }
+
+    function taskRowDataFromRow(row) {
+        if (!row) return null;
+        return {
+            type: ((row.querySelector('.type-cell') || {}).textContent || '').trim(),
+            job: ((row.querySelector('.job-cell') || {}).textContent || '').trim(),
+            meta: ((row.querySelector('.meta-cell') || {}).textContent || '').trim()
+        };
+    }
+
+    function workflowPhaseDataFromRow(row) {
+        if (!row) return null;
+        return {
+            type: ((row.querySelector('.task-cell') || {}).textContent || '').trim(),
+            job: ((row.querySelector('.job-cell') || {}).textContent || '').trim(),
+            workflow: ((row.querySelector('.workflow-file-cell') || {}).textContent || '').trim()
+        };
+    }
+
+    function taskRowDataFromCell(cell) {
+        return taskRowDataFromRow(cell && cell.closest('tr'));
+    }
+
+    function navigateToBackload(rowData) {
+        if (!rowData || !rowData.type) return;
+        window.location.href = buildBackloadUrl(rowData);
+    }
+
+    function enableRowBackloadActions(root, getRowData) {
+        const el = typeof root === 'string' ? document.querySelector(root) : root;
+        if (!el || !getRowData) return;
+
+        el.addEventListener('click', function(e) {
+            const btn = e.target.closest('.row-action-btn');
+            if (!btn || !el.contains(btn)) return;
+            e.stopPropagation();
+            navigateToBackload(getRowData(btn.closest('tr')));
+        });
+    }
+
     function showActionBar(cell, options) {
         removeActionBar();
 
@@ -335,6 +408,13 @@
         enableCellActions: enableCellActions,
         showCopyFeedback: showCopyFeedback,
         deactivateCell: deactivateCell,
-        copyCell: copyCell
+        copyCell: copyCell,
+        parseMetaString: parseMetaString,
+        buildBackloadUrl: buildBackloadUrl,
+        navigateToBackload: navigateToBackload,
+        taskRowDataFromRow: taskRowDataFromRow,
+        taskRowDataFromCell: taskRowDataFromCell,
+        workflowPhaseDataFromRow: workflowPhaseDataFromRow,
+        enableRowBackloadActions: enableRowBackloadActions
     };
 })();
diff --git a/apps/flowlord/handler/task.tmpl b/apps/flowlord/handler/task.tmpl
index b34ea10..c965e00 100644
--- a/apps/flowlord/handler/task.tmpl
+++ b/apps/flowlord/handler/task.tmpl
@@ -109,6 +109,7 @@
             <table id="taskTable">
                 <thead>
                     <tr>
+                        <th class="row-action-col" aria-hidden="true"></th>
                         <th class="sortable filterable id-column{{if eq .Filter.Sort "id"}}{{if eq .Filter.Direction "desc"}} sort-desc{{else}} sort-asc{{end}}{{end}}{{if .Filter.ID}} has-filter{{end}}" data-sort="id" data-filter="id">
                             <div class="th-inner">
                                 <button type="button" class="th-sort">ID</button>
@@ -165,6 +166,14 @@
                     {{if .Tasks}}
                     {{range .Tasks}}
                     <tr>
+                        <td class="row-action-col">
+                            <button type="button" class="row-action-btn row-action-replay" aria-label="Rerun" title="Rerun">
+                                <svg class="row-action-icon" viewBox="0 0 24 24" aria-hidden="true" fill="none" stroke="currentColor" stroke-width="2.5" stroke-linecap="round" stroke-linejoin="round">
+                                    <path d="M3 12a9 9 0 1 0 9-9 9.75 9.75 0 0 0-6.74 2.74L3 8"/>
+                                    <path d="M3 3v5h5"/>
+                                </svg>
+                            </button>
+                        </td>
                         <td class="id-cell id-column expandable copyable" data-filter-key="id" title="Click for actions">{{.ID}}</td>
                         <td class="type-cell type-column copyable" data-filter-key="type" title="Click for actions">{{.Type}}</td>
                         <td class="job-cell job-column copyable" data-filter-key="job" title="Click for actions">{{.Job}}</td>
@@ -181,7 +190,7 @@
                     {{end}}
                     {{else}}
                     <tr>
-                        <td colspan="10" class="no-tasks-cell">
+                        <td colspan="11" class="no-tasks-cell">
                             <h3>No tasks found</h3>
                             <p>No tasks were found for {{.Date}} with the current filters.</p>
                         </td>
diff --git a/apps/flowlord/handler/workflow.tmpl b/apps/flowlord/handler/workflow.tmpl
index 4cca871..d20cd66 100644
--- a/apps/flowlord/handler/workflow.tmpl
+++ b/apps/flowlord/handler/workflow.tmpl
@@ -56,8 +56,20 @@
         {{if .Phases}}
         <div class="table-container">
             <table id="workflowTable">
+                <colgroup>
+                    <col style="width: 21px">
+                    <col style="width: 9%">
+                    <col style="width: 9%">
+                    <col style="width: 9%">
+                    <col style="width: 22%">
+                    <col style="width: 11%">
+                    <col style="width: 5%">
+                    <col style="width: 22%">
+                    <col style="width: 13%">
+                </colgroup>
                 <thead>
                     <tr>
+                        <th class="row-action-col" aria-hidden="true"></th>
                         <th class="sortable workflow-file-cell" data-sort="workflow_file">Workflow</th>
                         <th class="sortable task-cell" data-sort="task">Topic</th>
                         <th class="sortable job-cell" data-sort="job">Job</th>
@@ -71,6 +83,13 @@
                 <tbody>
                     {{range .Phases}}
                     <tr>
+                        <td class="row-action-col">
+                            <button type="button" class="row-action-btn row-action-play" aria-label="Run" title="Run">
+                                <svg class="row-action-icon" viewBox="0 0 24 24" aria-hidden="true" fill="currentColor">
+                                    <path d="M7 4.5v15l13-7.5z"/>
+                                </svg>
+                            </button>
+                        </td>
                         <td class="workflow-file-cell copyable" title="Click for actions">{{.FilePath}}</td>
                         <td class="task-cell copyable" title="Click for actions">{{.Topic}}</td>
                         <td class="job-cell copyable" title="Click for actions">{{.Job}}</td>
@@ -122,6 +141,7 @@
             const tbody = document.querySelector('#workflowTable tbody');
             if (tbody && window.FlowlordUtils) {
                 window.FlowlordUtils.enableCellActions(tbody);
+                window.FlowlordUtils.enableRowBackloadActions(tbody, window.FlowlordUtils.workflowPhaseDataFromRow);
             }
 
             // Initialize filters
@@ -146,9 +166,9 @@
             const jobMap = new Map(); // task -> Set of jobs
             
             rows.forEach(row => {
-                const workflowCell = row.cells[0];
-                const taskCell = row.cells[1];
-                const jobCell = row.cells[2];
+                const workflowCell = row.querySelector('.workflow-file-cell');
+                const taskCell = row.querySelector('.task-cell');
+                const jobCell = row.querySelector('.job-cell');
                 
                 if (workflowCell && taskCell && jobCell) {
                     const workflow = workflowCell.textContent.trim();
@@ -229,9 +249,9 @@
             const rows = Array.from(table.querySelectorAll('tbody tr'));
             
             rows.forEach(row => {
-                const workflowCell = row.cells[0];
-                const taskCell = row.cells[1];
-                const jobCell = row.cells[2];
+                const workflowCell = row.querySelector('.workflow-file-cell');
+                const taskCell = row.querySelector('.task-cell');
+                const jobCell = row.querySelector('.job-cell');
                 
                 if (workflowCell && taskCell && jobCell) {
                     const workflow = workflowCell.textContent.trim();
diff --git a/apps/flowlord/handler_test.go b/apps/flowlord/handler_test.go
index 02c0ec6..1512304 100644
--- a/apps/flowlord/handler_test.go
+++ b/apps/flowlord/handler_test.go
@@ -92,6 +92,19 @@ func TestBackloader(t *testing.T) {
 				Tasks: []task.Task{{Type: "task1", Info: "?date=2022-06-12", Meta: "cron=2022-06-12T00&workflow=f3.toml"}},
 			},
 		},
+		"from_cache_with_workflow": {
+			Input: request{
+				Batch: Batch{
+					Task:     "task1",
+					Workflow: "f3.toml",
+				},
+				At: "2022-06-12",
+			},
+			Expected: response{
+				Count: 1,
+				Tasks: []task.Task{{Type: "task1", Info: "?date=2022-06-12", Meta: "cron=2022-06-12T00&workflow=f3.toml"}},
+			},
+		},
 		"hourly": {
 			Input: request{
 				Batch: Batch{
diff --git a/apps/flowlord/sqlite/workflow.go b/apps/flowlord/sqlite/workflow.go
index de4103b..636f1ea 100644
--- a/apps/flowlord/sqlite/workflow.go
+++ b/apps/flowlord/sqlite/workflow.go
@@ -93,6 +93,40 @@ func (s *SQLite) Search(taskType, job string) PhaseDB {
 	return s.Get(task.Task{Type: taskType, Job: job})
 }
 
+// GetPhase returns the phase for a specific workflow file, task type, and job.
+func (s *SQLite) GetPhase(filePath, taskType, job string) PhaseDB {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
+	key := taskType
+	if job != "" {
+		key += ":" + job
+	}
+
+	query := `
+		SELECT file_path, task, depends_on, rule, template, retry
+		FROM workflow_phases 
+		WHERE file_path = ? AND task = ?
+		LIMIT 1
+	`
+	rows, err := s.db.Query(query, filePath, key)
+	if err != nil {
+		return PhaseDB{Status: err.Error()}
+	}
+	defer rows.Close()
+
+	if rows.Next() {
+		ph := PhaseDB{}
+		err := rows.Scan(&ph.FilePath, &ph.Task, &ph.DependsOn, &ph.Rule, &ph.Template, &ph.Retry)
+		if err != nil {
+			return PhaseDB{Status: err.Error()}
+		}
+		ph.Status = ph.Phase.Validate()
+		return ph
+	}
+	return PhaseDB{Status: "not found"}
+}
+
 // Get the Phase associated with the task
 // looks for matching phases within a workflow defined in meta
 // that matches the task Type and job.
diff --git a/apps/flowlord/sqlite/workflow_test.go b/apps/flowlord/sqlite/workflow_test.go
index c1585f6..45624df 100644
--- a/apps/flowlord/sqlite/workflow_test.go
+++ b/apps/flowlord/sqlite/workflow_test.go
@@ -330,3 +330,47 @@ func TestCache_FilePath(t *testing.T) {
 	}
 	trial.New(fn, cases).SubTest(t)
 }
+
+func TestGetPhase(t *testing.T) {
+	cache := MockSQLite()
+	if err := cache.updateWorkflowInDB("a.toml", "NA", []Phase{
+		{Task: "daily:load", Template: "?a={YYYY}-{MM}-{DD}", Rule: ""},
+	}); err != nil {
+		t.Fatal(err)
+	}
+	if err := cache.updateWorkflowInDB("b.toml", "NA", []Phase{
+		{Task: "daily:load", Template: "?b={YYYY}-{MM}-{DD}", Rule: ""},
+	}); err != nil {
+		t.Fatal(err)
+	}
+
+	type input struct {
+		file string
+		task string
+		job  string
+	}
+
+	fn := func(in input) (string, error) {
+		ph := cache.GetPhase(in.file, in.task, in.job)
+		if ph.FilePath == "" {
+			return "", errors.New(ph.Status)
+		}
+		return ph.Template, nil
+	}
+
+	cases := trial.Cases[input, string]{
+		"workflow a": {
+			Input:    input{file: "a.toml", task: "daily", job: "load"},
+			Expected: "?a={YYYY}-{MM}-{DD}",
+		},
+		"workflow b": {
+			Input:    input{file: "b.toml", task: "daily", job: "load"},
+			Expected: "?b={YYYY}-{MM}-{DD}",
+		},
+		"missing workflow": {
+			Input:       input{file: "missing.toml", task: "daily", job: "load"},
+			ExpectedErr: errors.New("not found"),
+		},
+	}
+	trial.New(fn, cases).SubTest(t)
+}
diff --git a/apps/flowlord/test/seed_dev.sql b/apps/flowlord/test/seed_dev.sql
new file mode 100644
index 0000000..851f3e4
--- /dev/null
+++ b/apps/flowlord/test/seed_dev.sql
@@ -0,0 +1,77 @@
+-- Dev seed: same-day tasks + alerts for local UI testing (Alerts ID → Tasks).
+--
+-- DataGrip: open tasks.db (repo root), then run this file against it.
+-- Safe to re-run: only rows with id/task_id like 'seed-%' (and tagged unknown) are replaced.
+-- Dates use UTC today so the dashboard date picker default (today) shows the data.
+
+BEGIN;
+
+DELETE FROM task_records WHERE id LIKE 'seed-%';
+DELETE FROM alert_records WHERE task_id LIKE 'seed-%'
+   OR (task_id = 'unknown' AND msg LIKE '[seed]%');
+
+INSERT INTO task_records (id, type, job, info, result, meta, msg, created, started, ended) VALUES
+-- One pipeline ID, three phases (what the Alerts ID click should list)
+(
+    'seed-pipeline', 'task1', 't2',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T11',
+    'complete', 'cron=' || date('now') || 'T11', 'ok',
+    date('now') || 'T11:00:00Z', date('now') || 'T11:00:05Z', date('now') || 'T11:00:30Z'
+),
+(
+    'seed-pipeline', 'task2', '',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T12',
+    'alert', 'cron=' || date('now') || 'T12', 'downstream alert: missing file',
+    date('now') || 'T12:00:00Z', date('now') || 'T12:00:02Z', date('now') || 'T12:00:10Z'
+),
+(
+    'seed-pipeline', 'task3', '',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T12',
+    'error', 'cron=' || date('now') || 'T12', 'child failed after parent alert',
+    date('now') || 'T12:05:00Z', date('now') || 'T12:05:01Z', date('now') || 'T12:05:08Z'
+),
+-- Same type:job:id, two created hours (second instance of the ID that day)
+(
+    'seed-hourly', 'task1', 't4',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T10',
+    'complete', 'cron=' || date('now') || 'T10', 'hour 10 complete',
+    date('now') || 'T10:00:00Z', date('now') || 'T10:00:01Z', date('now') || 'T10:00:02Z'
+),
+(
+    'seed-hourly', 'task1', 't4',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T13',
+    'alert', 'cron=' || date('now') || 'T13', 'hour 13 quality check failed',
+    date('now') || 'T13:00:00Z', date('now') || 'T13:00:01Z', date('now') || 'T13:00:04Z'
+),
+(
+    'seed-long-id-abcdefghijklmnopqrstuvwxyz12345', 'task1', 't2',
+    '?date=' || date('now') || '&hour=' || date('now') || 'T14',
+    'alert', 'cron=' || date('now') || 'T14', 'Validation failed: missing required field ''email''',
+    date('now') || 'T14:00:00Z', date('now') || 'T14:00:01Z', date('now') || 'T14:00:01Z'
+);
+
+INSERT INTO alert_records (task_id, task_time, task_type, job, msg, created_at) VALUES
+(
+    'seed-pipeline', date('now') || 'T12:00:00Z', 'task2', '',
+    'downstream alert: missing file', date('now') || 'T12:00:10Z'
+),
+(
+    'seed-hourly', date('now') || 'T13:00:00Z', 'task1', 't4',
+    'hour 13 quality check failed', date('now') || 'T13:00:04Z'
+),
+(
+    'seed-long-id-abcdefghijklmnopqrstuvwxyz12345', date('now') || 'T14:00:00Z', 'task1', 't2',
+    'Validation failed: missing required field ''email''', date('now') || 'T14:00:01Z'
+),
+-- No matching task; Alerts page should not link this ID
+(
+    'unknown', date('now') || 'T15:00:00Z', 'task1', 't2',
+    '[seed] send failure with empty task id', date('now') || 'T15:00:00Z'
+);
+
+INSERT OR IGNORE INTO date_index ("date") VALUES (date('now'));
+UPDATE date_index
+SET has_tasks = 1, has_alerts = 1
+WHERE "date" = date('now');
+
+COMMIT;

From 63bc61f193548779a3cf1eb40c666b106b45a932 Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Thu, 10 Sep 2026 14:32:13 -0600
Subject: [PATCH 2/6] feat(flowlord): Add task rerun from tasks page

  * Add POST /rerun to replay a task by primary key with sanitized meta and same pipeline ID.
  * Replace browser confirm with a details modal and redirect to today's tasks filtered by ID.
---
 apps/flowlord/handler.go               |   1 +
 apps/flowlord/handler/static/style.css |  92 +++++++++
 apps/flowlord/handler/static/task.js   | 255 ++++++++++++++++++++++---
 apps/flowlord/handler/task.tmpl        |  16 +-
 apps/flowlord/handler_test.go          |  95 +++++++++
 apps/flowlord/rerun.go                 |  95 +++++++++
 apps/flowlord/rerun_test.go            |  83 ++++++++
 apps/flowlord/sqlite/tasks.go          |  24 +++
 apps/flowlord/sqlite/tasks_test.go     |  34 ++++
 9 files changed, 670 insertions(+), 25 deletions(-)
 create mode 100644 apps/flowlord/rerun.go
 create mode 100644 apps/flowlord/rerun_test.go

diff --git a/apps/flowlord/handler.go b/apps/flowlord/handler.go
index 141b309..585a8f6 100644
--- a/apps/flowlord/handler.go
+++ b/apps/flowlord/handler.go
@@ -119,6 +119,7 @@ func (tm *taskMaster) StartHandler(serveErr chan<- error) error {
 	router.Get("/info", tm.Info)
 	router.Get("/refresh", tm.refreshHandler)
 	router.Post("/backload", tm.Backloader)
+	router.Post("/rerun", tm.rerunHandler)
 	router.Get("/workflow/*", tm.workflowFiles)
 	router.Get("/workflow", tm.workflowFiles)
 	router.Get("/notify", func(w http.ResponseWriter, r *http.Request) {
diff --git a/apps/flowlord/handler/static/style.css b/apps/flowlord/handler/static/style.css
index 5492625..ebb87fa 100644
--- a/apps/flowlord/handler/static/style.css
+++ b/apps/flowlord/handler/static/style.css
@@ -1848,6 +1848,98 @@ th.row-action-col:hover {
     background-color: #f3ebff;
 }
 
+.row-action-replay:disabled,
+.row-action-replay.row-action-loading {
+    opacity: 0.55;
+    cursor: wait;
+}
+
+.rerun-modal {
+    position: fixed;
+    inset: 0;
+    z-index: 1100;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    padding: 16px;
+}
+
+.rerun-modal[hidden] {
+    display: none;
+}
+
+.rerun-modal-backdrop {
+    position: absolute;
+    inset: 0;
+    background: rgba(15, 23, 42, 0.45);
+}
+
+.rerun-modal-dialog {
+    position: relative;
+    width: min(560px, 100%);
+    max-height: min(80vh, 640px);
+    display: flex;
+    flex-direction: column;
+    background: #fff;
+    border: 1px solid #ced4da;
+    border-radius: 8px;
+    box-shadow: 0 16px 40px rgba(0, 0, 0, 0.18);
+    padding: 20px;
+}
+
+.rerun-modal-title {
+    margin: 0 0 8px;
+    font-size: 1.15rem;
+    font-weight: 600;
+    color: #212529;
+}
+
+.rerun-modal-lead {
+    margin: 0 0 16px;
+    font-size: 14px;
+    color: #495057;
+    line-height: 1.45;
+}
+
+.rerun-modal-details {
+    margin: 0 0 16px;
+    padding: 12px;
+    background: #f8f9fa;
+    border: 1px solid #e9ecef;
+    border-radius: 6px;
+    overflow: auto;
+    max-height: min(42vh, 360px);
+}
+
+.rerun-modal-details dt {
+    margin: 10px 0 4px;
+    font-size: 11px;
+    font-weight: 600;
+    text-transform: uppercase;
+    letter-spacing: 0.03em;
+    color: #6c757d;
+}
+
+.rerun-modal-details dt:first-child {
+    margin-top: 0;
+}
+
+.rerun-modal-details dd {
+    margin: 0;
+    font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;
+    font-size: 13px;
+    color: #212529;
+    white-space: pre-wrap;
+    word-break: break-word;
+}
+
+.rerun-modal-actions {
+    display: flex;
+    gap: 8px;
+    justify-content: flex-end;
+    flex-shrink: 0;
+}
+
 .row-action-play {
     color: #198754;
 }
diff --git a/apps/flowlord/handler/static/task.js b/apps/flowlord/handler/static/task.js
index ef4ed9d..32e45e0 100644
--- a/apps/flowlord/handler/static/task.js
+++ b/apps/flowlord/handler/static/task.js
@@ -10,6 +10,27 @@
         { value: 'running', label: 'Running' }
     ];
 
+    function saveTaskPageScroll() {
+        try {
+            sessionStorage.setItem('flowlordTaskScrollY', String(window.scrollY));
+        } catch (e) { /* ignore */ }
+    }
+
+    function restoreTaskPageScroll() {
+        var y = null;
+        try {
+            y = sessionStorage.getItem('flowlordTaskScrollY');
+            sessionStorage.removeItem('flowlordTaskScrollY');
+        } catch (e) {
+            return;
+        }
+        if (y === null) return;
+        var top = parseInt(y, 10);
+        if (!isNaN(top)) {
+            window.scrollTo(0, top);
+        }
+    }
+
     function initTaskPage(config) {
         config = config || {};
         var table = document.getElementById('taskTable');
@@ -74,27 +95,6 @@
             };
         }
 
-        function saveScroll() {
-            try {
-                sessionStorage.setItem('flowlordTaskScrollY', String(window.scrollY));
-            } catch (e) { /* ignore */ }
-        }
-
-        function restoreScroll() {
-            var y = null;
-            try {
-                y = sessionStorage.getItem('flowlordTaskScrollY');
-                sessionStorage.removeItem('flowlordTaskScrollY');
-            } catch (e) {
-                return;
-            }
-            if (y === null) return;
-            var top = parseInt(y, 10);
-            if (!isNaN(top)) {
-                window.scrollTo(0, top);
-            }
-        }
-
         function setListParam(url, key, values) {
             url.searchParams.delete(key);
             values = toArray(values);
@@ -125,7 +125,7 @@
             }
 
             url.searchParams.delete('page');
-            saveScroll();
+            saveTaskPageScroll();
             window.location.href = url.toString();
         }
 
@@ -509,13 +509,220 @@
                 window.FlowlordUtils.enableCellActions(tbody, {
                     onFilter: applyFilter
                 });
-                window.FlowlordUtils.enableRowBackloadActions(tbody, window.FlowlordUtils.taskRowDataFromRow);
+                enableRowRerunActions(tbody, config.rerunEndpoint || '/rerun');
             }
         }
 
         window.FlowlordTask.applyFilter = applyFilter;
 
-        restoreScroll();
+        restoreTaskPageScroll();
+    }
+
+    var rerunModalPending = null;
+
+    function taskPageBase() {
+        return window.location.pathname.includes('_preview') ? './task_preview.html' : '/web/task';
+    }
+
+    function rerunCellText(row, selector) {
+        const cell = row.querySelector(selector);
+        if (!cell) return '';
+        if (window.FlowlordUtils && window.FlowlordUtils.copyableText) {
+            return window.FlowlordUtils.copyableText(cell).trim();
+        }
+        return (cell.textContent || '').trim();
+    }
+
+    function rerunTaskLabel(details) {
+        const type = details.type || '';
+        const job = details.job || '';
+        return job ? type + ':' + job : type;
+    }
+
+    function rerunPayloadFromDetails(details) {
+        return {
+            type: details.type || '',
+            job: details.job || '',
+            id: details.id || '',
+            created: details.created || ''
+        };
+    }
+
+    function rerunDetailsFromRow(row) {
+        return {
+            type: row.getAttribute('data-rerun-type') || '',
+            job: row.getAttribute('data-rerun-job') || '',
+            id: row.getAttribute('data-rerun-id') || '',
+            created: row.getAttribute('data-rerun-created') || '',
+            result: row.getAttribute('data-rerun-result') || '',
+            info: rerunCellText(row, '.info-cell'),
+            meta: rerunCellText(row, '.meta-cell'),
+            msg: rerunCellText(row, '.message-cell')
+        };
+    }
+
+    function rerunTasksHref(task) {
+        const id = task && task.id;
+        if (!id) return taskPageBase();
+        let date = '';
+        if (task.created) {
+            date = String(task.created).slice(0, 10);
+        }
+        if (!/^\d{4}-\d{2}-\d{2}$/.test(date)) {
+            date = new Date().toISOString().split('T')[0];
+        }
+        return taskPageBase() + '?date=' + encodeURIComponent(date) + '&id=' + encodeURIComponent(id);
+    }
+
+    function messageFromRerunResponse(responseText, status) {
+        if (responseText) {
+            try {
+                const j = JSON.parse(responseText);
+                if (j && typeof j.Status === 'string' && j.Status.length > 0) {
+                    return j.Status;
+                }
+            } catch (e) { /* use raw */ }
+            const trimmed = String(responseText).trim();
+            if (trimmed) {
+                return trimmed;
+            }
+        }
+        if (status === 404) {
+            return 'Task not found — refresh the page';
+        }
+        return 'Rerun failed';
+    }
+
+    function appendRerunDetail(container, label, value) {
+        if (!value) return;
+        const dt = document.createElement('dt');
+        dt.textContent = label;
+        const dd = document.createElement('dd');
+        dd.textContent = value;
+        container.appendChild(dt);
+        container.appendChild(dd);
+    }
+
+    function closeRerunModal() {
+        const modal = document.getElementById('rerunModal');
+        if (!modal) return;
+        modal.hidden = true;
+        modal.setAttribute('aria-hidden', 'true');
+        rerunModalPending = null;
+        document.removeEventListener('keydown', onRerunModalKeydown);
+    }
+
+    function onRerunModalKeydown(e) {
+        if (e.key === 'Escape') {
+            closeRerunModal();
+        }
+    }
+
+    function openRerunModal(details, onConfirm) {
+        const modal = document.getElementById('rerunModal');
+        const detailsEl = document.getElementById('rerunModalDetails');
+        const confirmBtn = document.getElementById('rerunModalConfirm');
+        const cancelBtn = document.getElementById('rerunModalCancel');
+        if (!modal || !detailsEl || !confirmBtn || !cancelBtn) {
+            return;
+        }
+
+        detailsEl.innerHTML = '';
+        appendRerunDetail(detailsEl, 'Task', rerunTaskLabel(details));
+        appendRerunDetail(detailsEl, 'ID', details.id);
+        appendRerunDetail(detailsEl, 'Result', details.result);
+        appendRerunDetail(detailsEl, 'Created', details.created);
+        appendRerunDetail(detailsEl, 'Info', details.info);
+        appendRerunDetail(detailsEl, 'Meta', details.meta);
+        appendRerunDetail(detailsEl, 'Message', details.msg);
+
+        const title = document.getElementById('rerunModalTitle');
+        if (title) {
+            title.textContent = 'Rerun ' + rerunTaskLabel(details);
+        }
+
+        rerunModalPending = { onConfirm: onConfirm };
+        modal.hidden = false;
+        modal.setAttribute('aria-hidden', 'false');
+        document.addEventListener('keydown', onRerunModalKeydown);
+        confirmBtn.focus();
+
+        function handleConfirm() {
+            const pending = rerunModalPending;
+            closeRerunModal();
+            if (pending && pending.onConfirm) {
+                pending.onConfirm();
+            }
+        }
+
+        confirmBtn.onclick = handleConfirm;
+        cancelBtn.onclick = closeRerunModal;
+        modal.querySelectorAll('[data-rerun-dismiss]').forEach(function(el) {
+            el.onclick = closeRerunModal;
+        });
+    }
+
+    function executeRerun(btn, payload, apiEndpoint) {
+        btn.disabled = true;
+        btn.classList.add('row-action-loading');
+
+        fetch(apiEndpoint, {
+            method: 'POST',
+            headers: { 'Content-Type': 'application/json' },
+            body: JSON.stringify(payload)
+        }).then(function(response) {
+            return response.text().then(function(text) {
+                if (!response.ok) {
+                    const errMsg = messageFromRerunResponse(text, response.status);
+                    if (window.FlowlordUtils && window.FlowlordUtils.showCopyFeedback) {
+                        window.FlowlordUtils.showCopyFeedback(btn, errMsg, true);
+                    }
+                    btn.disabled = false;
+                    btn.classList.remove('row-action-loading');
+                    return;
+                }
+
+                let task = null;
+                try {
+                    const data = JSON.parse(text);
+                    task = data && data.Task;
+                } catch (e) { /* ignore */ }
+
+                saveTaskPageScroll();
+                window.location.href = rerunTasksHref(task || { id: payload.id });
+            });
+        }).catch(function(err) {
+            const errMsg = err && err.message ? err.message : 'Rerun failed';
+            if (window.FlowlordUtils && window.FlowlordUtils.showCopyFeedback) {
+                window.FlowlordUtils.showCopyFeedback(btn, errMsg, true);
+            }
+            btn.disabled = false;
+            btn.classList.remove('row-action-loading');
+        });
+    }
+
+    function enableRowRerunActions(root, apiEndpoint) {
+        const el = typeof root === 'string' ? document.querySelector(root) : root;
+        if (!el) return;
+
+        el.addEventListener('click', function(e) {
+            const btn = e.target.closest('.row-action-replay');
+            if (!btn || !el.contains(btn) || btn.disabled) return;
+            e.stopPropagation();
+
+            const row = btn.closest('tr');
+            if (!row) return;
+
+            const details = rerunDetailsFromRow(row);
+            const payload = rerunPayloadFromDetails(details);
+            if (!payload.type || !payload.id || !payload.created) {
+                return;
+            }
+
+            openRerunModal(details, function() {
+                executeRerun(btn, payload, apiEndpoint);
+            });
+        });
     }
 
     window.clearFilters = function() {
diff --git a/apps/flowlord/handler/task.tmpl b/apps/flowlord/handler/task.tmpl
index c965e00..4b88d2e 100644
--- a/apps/flowlord/handler/task.tmpl
+++ b/apps/flowlord/handler/task.tmpl
@@ -165,7 +165,7 @@
                 <tbody>
                     {{if .Tasks}}
                     {{range .Tasks}}
-                    <tr>
+                    <tr data-rerun-type="{{.Type}}" data-rerun-job="{{.Job}}" data-rerun-id="{{.ID}}" data-rerun-created="{{.Created}}" data-rerun-result="{{.Result}}">
                         <td class="row-action-col">
                             <button type="button" class="row-action-btn row-action-replay" aria-label="Rerun" title="Rerun">
                                 <svg class="row-action-icon" viewBox="0 0 24 24" aria-hidden="true" fill="none" stroke="currentColor" stroke-width="2.5" stroke-linecap="round" stroke-linejoin="round">
@@ -223,12 +223,26 @@
         {{end}}
     </div>
 
+    <div id="rerunModal" class="rerun-modal" hidden aria-hidden="true">
+        <div class="rerun-modal-backdrop" data-rerun-dismiss></div>
+        <div class="rerun-modal-dialog" role="dialog" aria-modal="true" aria-labelledby="rerunModalTitle">
+            <h2 id="rerunModalTitle" class="rerun-modal-title">Rerun task</h2>
+            <p class="rerun-modal-lead">This task will have the same ID, info and metadata as the original</p>
+            <dl class="rerun-modal-details" id="rerunModalDetails"></dl>
+            <div class="rerun-modal-actions">
+                <button type="button" class="btn btn-secondary" id="rerunModalCancel">No</button>
+                <button type="button" class="btn btn-primary" id="rerunModalConfirm">Yes, rerun</button>
+            </div>
+        </div>
+    </div>
+
     <script src="{{if .isLocal}}./static{{else}}/static{{end}}/task.js"></script>
     <script>
         // Initialize task page with server-provided configuration
         document.addEventListener('DOMContentLoaded', function() {
             if (window.FlowlordTask) {
                 const config = {
+                    rerunEndpoint: '/rerun',
                     taskTypes: [{{range $i, $t := .UniqueTypes}}{{if $i}},{{end}}"{{$t}}"{{end}}],
                     jobsByType: [
                         {{range $type, $jobs := .JobsByType}}
diff --git a/apps/flowlord/handler_test.go b/apps/flowlord/handler_test.go
index 1512304..a4a46c2 100644
--- a/apps/flowlord/handler_test.go
+++ b/apps/flowlord/handler_test.go
@@ -1,8 +1,12 @@
 package main
 
 import (
+	"bytes"
+	"database/sql"
 	"encoding/json"
 	"errors"
+	"net/http"
+	"net/http/httptest"
 	"os"
 	"strings"
 	"testing"
@@ -10,6 +14,7 @@ import (
 
 	"github.com/hydronica/trial"
 	"github.com/pcelvng/task"
+	"github.com/pcelvng/task/bus/nop"
 
 	"github.com/pcelvng/task-tools/apps/flowlord/sqlite"
 )
@@ -706,3 +711,93 @@ func TestAboutHTML(t *testing.T) {
 		t.Error("Expected 'Table Breakdown' in HTML output")
 	}
 }
+
+func TestRerun(t *testing.T) {
+	sqlDB := &sqlite.SQLite{LocalPath: ":memory:"}
+	if err := sqlDB.Open(testPath+"/workflow/f3.toml", nil); err != nil {
+		t.Fatal(err)
+	}
+	created := "2024-01-15T10:00:00Z"
+	sqlDB.Add(task.Task{
+		ID:      "rerun-src",
+		Type:    "task1",
+		Job:     "",
+		Info:    "?date=2024-01-15",
+		Meta:    "retry=2&delayed=50ms&workflow=f3.toml",
+		Result:  task.ErrResult,
+		Created: created,
+	})
+
+	producer, err := nop.NewProducer("")
+	if err != nil {
+		t.Fatal(err)
+	}
+	tm := &taskMaster{
+		taskCache: sqlDB,
+		producer:  producer,
+	}
+
+	doRerun := func(req rerunRequest) (*httptest.ResponseRecorder, rerunResponse) {
+		body, _ := json.Marshal(req)
+		r := httptest.NewRequest(http.MethodPost, "/rerun", bytes.NewReader(body))
+		w := httptest.NewRecorder()
+		tm.rerunHandler(w, r)
+		var resp rerunResponse
+		if w.Code == http.StatusOK {
+			_ = json.Unmarshal(w.Body.Bytes(), &resp)
+		}
+		return w, resp
+	}
+
+	w, resp := doRerun(rerunRequest{
+		Type:    "task1",
+		ID:      "rerun-src",
+		Created: created,
+	})
+	if w.Code != http.StatusOK {
+		t.Fatalf("happy path status = %d, body = %s", w.Code, w.Body.String())
+	}
+	if resp.Status != "Rerun queued" {
+		t.Errorf("Status = %q, want Rerun queued", resp.Status)
+	}
+	if resp.Task.Info != "?date=2024-01-15" {
+		t.Errorf("Info = %q", resp.Task.Info)
+	}
+	if resp.Task.ID != "rerun-src" {
+		t.Errorf("ID = %q", resp.Task.ID)
+	}
+	if resp.Task.Created == created {
+		t.Error("expected new created timestamp")
+	}
+	if !strings.Contains(resp.Task.Meta, "rerun=manual") {
+		t.Errorf("Meta = %q, want rerun=manual", resp.Task.Meta)
+	}
+	if strings.Contains(resp.Task.Meta, "retry=") || strings.Contains(resp.Task.Meta, "delayed=") {
+		t.Errorf("retry meta not stripped: %q", resp.Task.Meta)
+	}
+	if len(producer.Messages["task1"]) != 1 {
+		t.Fatalf("messages sent = %d, want 1", len(producer.Messages["task1"]))
+	}
+
+	w, _ = doRerun(rerunRequest{
+		Type:    "task1",
+		ID:      "missing",
+		Created: created,
+	})
+	if w.Code != http.StatusNotFound {
+		t.Errorf("missing task status = %d, want 404", w.Code)
+	}
+
+	w, _ = doRerun(rerunRequest{
+		Type: "task1",
+		ID:   "rerun-src",
+	})
+	if w.Code != http.StatusBadRequest {
+		t.Errorf("missing created status = %d, want 400", w.Code)
+	}
+
+	_, err = sqlDB.GetTaskRecord("task1", "", "rerun-src", "2024-01-15T11:00:00Z")
+	if !errors.Is(err, sql.ErrNoRows) {
+		t.Errorf("wrong created lookup err = %v, want ErrNoRows", err)
+	}
+}
diff --git a/apps/flowlord/rerun.go b/apps/flowlord/rerun.go
new file mode 100644
index 0000000..3c6f452
--- /dev/null
+++ b/apps/flowlord/rerun.go
@@ -0,0 +1,95 @@
+package main
+
+import (
+	"database/sql"
+	"encoding/json"
+	"errors"
+	"io"
+	"net/http"
+	"net/url"
+
+	"github.com/pcelvng/task"
+)
+
+var rerunMetaDrop = []string{"retry", "retried", "delayed"}
+
+func sanitizeRerunMeta(meta string) (string, error) {
+	vals, err := url.ParseQuery(meta)
+	if err != nil {
+		return "", err
+	}
+	for _, k := range rerunMetaDrop {
+		vals.Del(k)
+	}
+	vals.Set("rerun", "manual")
+	s, err := url.QueryUnescape(vals.Encode())
+	if err != nil {
+		return "", err
+	}
+	return s, nil
+}
+
+func taskForRerun(orig task.Task) (*task.Task, error) {
+	meta, err := sanitizeRerunMeta(orig.Meta)
+	if err != nil {
+		return nil, err
+	}
+	t := task.NewWithID(orig.Type, orig.Info, orig.ID)
+	t.Job = orig.Job
+	t.Meta = meta
+	return t, nil
+}
+
+type rerunRequest struct {
+	Type    string `json:"type"`
+	Job     string `json:"job"`
+	ID      string `json:"id"`
+	Created string `json:"created"`
+}
+
+type rerunResponse struct {
+	Status string    `json:"Status"`
+	Task   task.Task `json:"Task"`
+}
+
+func (tm *taskMaster) rerunHandler(w http.ResponseWriter, r *http.Request) {
+	var req rerunRequest
+	b, _ := io.ReadAll(r.Body)
+	if err := json.Unmarshal(b, &req); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	if req.Type == "" || req.ID == "" || req.Created == "" {
+		http.Error(w, "type, id, and created are required", http.StatusBadRequest)
+		return
+	}
+
+	orig, err := tm.taskCache.GetTaskRecord(req.Type, req.Job, req.ID, req.Created)
+	if err != nil {
+		if errors.Is(err, sql.ErrNoRows) {
+			http.Error(w, "task not found", http.StatusNotFound)
+			return
+		}
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	t, err := taskForRerun(orig)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	tm.taskCache.Add(*t)
+	if err := tm.producer.Send(t.Type, t.JSONBytes()); err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	w.Header().Set("Content-Type", "application/json")
+	w.WriteHeader(http.StatusOK)
+	_ = json.NewEncoder(w).Encode(rerunResponse{
+		Status: "Rerun queued",
+		Task:   *t,
+	})
+}
diff --git a/apps/flowlord/rerun_test.go b/apps/flowlord/rerun_test.go
new file mode 100644
index 0000000..9c1d4d8
--- /dev/null
+++ b/apps/flowlord/rerun_test.go
@@ -0,0 +1,83 @@
+package main
+
+import (
+	"errors"
+	"net/url"
+	"testing"
+
+	"github.com/hydronica/trial"
+	"github.com/pcelvng/task"
+)
+
+func TestSanitizeRerunMeta(t *testing.T) {
+	fn := func(in string) (string, error) {
+		return sanitizeRerunMeta(in)
+	}
+	cases := trial.Cases[string, string]{
+		"strips retry state": {
+			Input:    "workflow=f1.toml&retry=3&retried=3&delayed=500ms&file=x",
+			Expected: "file=x&rerun=manual&workflow=f1.toml",
+		},
+		"preserves template meta": {
+			Input:    "cron=2022-06-12T00&workflow=f3.toml&key=fruit&val=apple",
+			Expected: "cron=2022-06-12T00&key=fruit&rerun=manual&val=apple&workflow=f3.toml",
+		},
+		"empty meta": {
+			Input:    "",
+			Expected: "rerun=manual",
+		},
+		"invalid meta": {
+			Input:       "%",
+			ExpectedErr: errors.New("invalid URL escape \"%\""),
+		},
+	}
+	trial.New(fn, cases).SubTest(t)
+}
+
+func TestTaskForRerun(t *testing.T) {
+	orig := task.Task{
+		Type:    "task1",
+		Job:     "t2",
+		Info:    "?date=2019-12-12",
+		ID:      "UUID_task1",
+		Meta:    "retry=2&retried=2&delayed=100ms&workflow=f1.toml",
+		Result:  task.ErrResult,
+		Msg:     "failed",
+		Created: "2019-12-12T10:00:00Z",
+	}
+
+	got, err := taskForRerun(orig)
+	if err != nil {
+		t.Fatalf("taskForRerun: %v", err)
+	}
+	if got.Type != orig.Type || got.Job != orig.Job || got.Info != orig.Info || got.ID != orig.ID {
+		t.Errorf("got type/job/info/id = %q/%q/%q/%q, want %q/%q/%q/%q",
+			got.Type, got.Job, got.Info, got.ID, orig.Type, orig.Job, orig.Info, orig.ID)
+	}
+	if got.Meta != "rerun=manual&workflow=f1.toml" {
+		t.Errorf("Meta = %q, want rerun=manual&workflow=f1.toml", got.Meta)
+	}
+	if got.Created == orig.Created {
+		t.Errorf("Created = %q, want different from source %q", got.Created, orig.Created)
+	}
+	if got.Created == "" {
+		t.Error("Created is empty")
+	}
+	if got.Result != "" {
+		t.Errorf("Result = %q, want empty", got.Result)
+	}
+	if got.Msg != "" {
+		t.Errorf("Msg = %q, want empty", got.Msg)
+	}
+
+	meta, err := url.ParseQuery(got.Meta)
+	if err != nil {
+		t.Fatalf("parse meta: %v", err)
+	}
+	if meta.Get("rerun") != "manual" {
+		t.Errorf("rerun = %q, want manual", meta.Get("rerun"))
+	}
+	if meta.Get("retry") != "" || meta.Get("retried") != "" || meta.Get("delayed") != "" {
+		t.Errorf("retry meta not stripped: %v", got.Meta)
+	}
+}
diff --git a/apps/flowlord/sqlite/tasks.go b/apps/flowlord/sqlite/tasks.go
index e31f968..5f8da0c 100644
--- a/apps/flowlord/sqlite/tasks.go
+++ b/apps/flowlord/sqlite/tasks.go
@@ -1,6 +1,7 @@
 package sqlite
 
 import (
+	"database/sql"
 	"fmt"
 	"log"
 	"net/url"
@@ -147,6 +148,29 @@ func (s *SQLite) GetTask(id string) TaskJob {
 	return tj
 }
 
+// GetTaskRecord returns a single task record by its primary key (type, job, id, created).
+func (s *SQLite) GetTaskRecord(taskType, job, id, created string) (task.Task, error) {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
+	var t task.Task
+	err := s.db.QueryRow(`
+		SELECT id, type, job, info, result, meta, msg, created, started, ended
+		FROM task_records
+		WHERE type = ? AND job = ? AND id = ? AND created = ?
+	`, taskType, job, id, created).Scan(
+		&t.ID, &t.Type, &t.Job, &t.Info, &t.Result, &t.Meta, &t.Msg,
+		&t.Created, &t.Started, &t.Ended,
+	)
+	if err != nil {
+		if err == sql.ErrNoRows {
+			return task.Task{}, sql.ErrNoRows
+		}
+		return task.Task{}, err
+	}
+	return t, nil
+}
+
 // Recycle cleans up any records older than day in the DB tables: files, alerts and tasks.
 func (s *SQLite) Recycle(t time.Time) (string, error) {
 	s.mu.Lock()
diff --git a/apps/flowlord/sqlite/tasks_test.go b/apps/flowlord/sqlite/tasks_test.go
index 8326309..3cee5f7 100644
--- a/apps/flowlord/sqlite/tasks_test.go
+++ b/apps/flowlord/sqlite/tasks_test.go
@@ -219,3 +219,37 @@ func TestAddStoresRunningForEmptyResult(t *testing.T) {
 		t.Errorf("result after complete = %q, want %q", result, task.CompleteResult)
 	}
 }
+
+func TestGetTaskRecord(t *testing.T) {
+	db := &SQLite{LocalPath: ":memory:"}
+	if err := db.initDB(); err != nil {
+		t.Fatalf("initDB: %v", err)
+	}
+	defer db.Close()
+
+	created := "2024-01-15T10:00:00Z"
+	want := task.Task{
+		ID:      "pipeline-1",
+		Type:    "alpha",
+		Job:     "load",
+		Info:    "?date=2024-01-15",
+		Meta:    "workflow=f1.toml",
+		Result:  task.ErrResult,
+		Msg:     "boom",
+		Created: created,
+	}
+	db.Add(want)
+
+	got, err := db.GetTaskRecord("alpha", "load", "pipeline-1", created)
+	if err != nil {
+		t.Fatalf("GetTaskRecord: %v", err)
+	}
+	if got.Info != want.Info || got.Meta != want.Meta || got.ID != want.ID {
+		t.Errorf("got %+v, want %+v", got, want)
+	}
+
+	_, err = db.GetTaskRecord("alpha", "load", "pipeline-1", "2024-01-15T11:00:00Z")
+	if err == nil {
+		t.Fatal("expected error for wrong created")
+	}
+}

From a2b81d9165385ff67cebdcb718646aed783ffcd9 Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Fri, 11 Sep 2026 13:30:28 -0600
Subject: [PATCH 3/6] fix(flowlord): mark failed sends as error

  * Update SendFunc and rerun to persist error when producer send fails instead of leaving running records
  * Return encoded rerun meta and remove unused task row helpers from the UI
---
 apps/flowlord/handler/static/utils.js | 15 ------
 apps/flowlord/handler_test.go         | 56 ++++++++++++++++++++
 apps/flowlord/rerun.go                | 10 ++--
 apps/flowlord/rerun_test.go           | 12 +++++
 apps/flowlord/sqlite/tasks.go         | 15 +++++-
 apps/flowlord/sqlite/tasks_test.go    | 74 +++++++++++++++++++++++++++
 6 files changed, 159 insertions(+), 23 deletions(-)

diff --git a/apps/flowlord/handler/static/utils.js b/apps/flowlord/handler/static/utils.js
index e9ee429..b59a9f2 100644
--- a/apps/flowlord/handler/static/utils.js
+++ b/apps/flowlord/handler/static/utils.js
@@ -232,15 +232,6 @@
         return base + '?' + params.toString();
     }
 
-    function taskRowDataFromRow(row) {
-        if (!row) return null;
-        return {
-            type: ((row.querySelector('.type-cell') || {}).textContent || '').trim(),
-            job: ((row.querySelector('.job-cell') || {}).textContent || '').trim(),
-            meta: ((row.querySelector('.meta-cell') || {}).textContent || '').trim()
-        };
-    }
-
     function workflowPhaseDataFromRow(row) {
         if (!row) return null;
         return {
@@ -250,10 +241,6 @@
         };
     }
 
-    function taskRowDataFromCell(cell) {
-        return taskRowDataFromRow(cell && cell.closest('tr'));
-    }
-
     function navigateToBackload(rowData) {
         if (!rowData || !rowData.type) return;
         window.location.href = buildBackloadUrl(rowData);
@@ -412,8 +399,6 @@
         parseMetaString: parseMetaString,
         buildBackloadUrl: buildBackloadUrl,
         navigateToBackload: navigateToBackload,
-        taskRowDataFromRow: taskRowDataFromRow,
-        taskRowDataFromCell: taskRowDataFromCell,
         workflowPhaseDataFromRow: workflowPhaseDataFromRow,
         enableRowBackloadActions: enableRowBackloadActions
     };
diff --git a/apps/flowlord/handler_test.go b/apps/flowlord/handler_test.go
index a4a46c2..56b4841 100644
--- a/apps/flowlord/handler_test.go
+++ b/apps/flowlord/handler_test.go
@@ -801,3 +801,59 @@ func TestRerun(t *testing.T) {
 		t.Errorf("wrong created lookup err = %v, want ErrNoRows", err)
 	}
 }
+
+func TestRerunProducerFailure(t *testing.T) {
+	sqlDB := &sqlite.SQLite{LocalPath: ":memory:"}
+	if err := sqlDB.Open(testPath+"/workflow/f3.toml", nil); err != nil {
+		t.Fatal(err)
+	}
+	created := "2024-01-15T10:00:00Z"
+	sqlDB.Add(task.Task{
+		ID:      "rerun-src",
+		Type:    "task1",
+		Job:     "",
+		Info:    "?date=2024-01-15",
+		Meta:    "retry=2&delayed=50ms&workflow=f3.toml",
+		Result:  task.ErrResult,
+		Created: created,
+	})
+
+	failProducer, err := nop.NewProducer("send_err")
+	if err != nil {
+		t.Fatal(err)
+	}
+	tm := &taskMaster{
+		taskCache: sqlDB,
+		producer:  failProducer,
+	}
+
+	body, _ := json.Marshal(rerunRequest{
+		Type:    "task1",
+		ID:      "rerun-src",
+		Created: created,
+	})
+	r := httptest.NewRequest(http.MethodPost, "/rerun", bytes.NewReader(body))
+	w := httptest.NewRecorder()
+	tm.rerunHandler(w, r)
+	if w.Code != http.StatusInternalServerError {
+		t.Fatalf("status = %d, want 500", w.Code)
+	}
+
+	tj := sqlDB.GetTask("rerun-src")
+	var newAttempts int
+	for _, evt := range tj.Events {
+		if evt.Created <= created {
+			continue
+		}
+		newAttempts++
+		if evt.Result == sqlite.ResultRunning {
+			t.Errorf("found running record after producer failure: %+v", evt)
+		}
+		if evt.Result != task.ErrResult {
+			t.Errorf("result = %q, want %q", evt.Result, task.ErrResult)
+		}
+	}
+	if newAttempts != 1 {
+		t.Fatalf("rerun attempts after failure = %d, want 1", newAttempts)
+	}
+}
diff --git a/apps/flowlord/rerun.go b/apps/flowlord/rerun.go
index 3c6f452..94557c9 100644
--- a/apps/flowlord/rerun.go
+++ b/apps/flowlord/rerun.go
@@ -22,11 +22,7 @@ func sanitizeRerunMeta(meta string) (string, error) {
 		vals.Del(k)
 	}
 	vals.Set("rerun", "manual")
-	s, err := url.QueryUnescape(vals.Encode())
-	if err != nil {
-		return "", err
-	}
-	return s, nil
+	return vals.Encode(), nil
 }
 
 func taskForRerun(orig task.Task) (*task.Task, error) {
@@ -80,8 +76,8 @@ func (tm *taskMaster) rerunHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	tm.taskCache.Add(*t)
-	if err := tm.producer.Send(t.Type, t.JSONBytes()); err != nil {
+	sendFunc := tm.taskCache.SendFunc(tm.producer)
+	if err := sendFunc(t.Type, t); err != nil {
 		http.Error(w, err.Error(), http.StatusInternalServerError)
 		return
 	}
diff --git a/apps/flowlord/rerun_test.go b/apps/flowlord/rerun_test.go
index 9c1d4d8..d54f066 100644
--- a/apps/flowlord/rerun_test.go
+++ b/apps/flowlord/rerun_test.go
@@ -30,6 +30,18 @@ func TestSanitizeRerunMeta(t *testing.T) {
 			Input:       "%",
 			ExpectedErr: errors.New("invalid URL escape \"%\""),
 		},
+		"encoded ampersand in value": {
+			Input:    "key=a%26b&workflow=f1.toml&retry=1",
+			Expected: "key=a%26b&rerun=manual&workflow=f1.toml",
+		},
+		"encoded plus in value": {
+			Input:    "key=a%2Bb&workflow=f1.toml&retry=1",
+			Expected: "key=a%2Bb&rerun=manual&workflow=f1.toml",
+		},
+		"encoded percent in value": {
+			Input:    "key=100%25&workflow=f1.toml&retry=1",
+			Expected: "key=100%25&rerun=manual&workflow=f1.toml",
+		},
 	}
 	trial.New(fn, cases).SubTest(t)
 }
diff --git a/apps/flowlord/sqlite/tasks.go b/apps/flowlord/sqlite/tasks.go
index 5f8da0c..dfd46e9 100644
--- a/apps/flowlord/sqlite/tasks.go
+++ b/apps/flowlord/sqlite/tasks.go
@@ -329,7 +329,20 @@ func (s *SQLite) Recap(day time.Time) TaskStats {
 func (s *SQLite) SendFunc(p bus.Producer) func(string, *task.Task) error {
 	return func(topic string, tsk *task.Task) error {
 		s.Add(*tsk)
-		return p.Send(topic, tsk.JSONBytes())
+		if err := p.Send(topic, tsk.JSONBytes()); err != nil {
+			s.mu.Lock()
+			_, dbErr := s.db.Exec(`
+				UPDATE task_records SET result = ?, msg = ?
+				WHERE type = ? AND job = ? AND id = ? AND created = ?
+			`, string(task.ErrResult), err.Error(), tsk.Type, tsk.Job, tsk.ID, tsk.Created)
+			s.mu.Unlock()
+			if dbErr != nil {
+				log.Printf("ERROR: Failed to mark send failure for task %s:%s:%s at %s: %v",
+					tsk.Type, tsk.Job, tsk.ID, tsk.Created, dbErr)
+			}
+			return err
+		}
+		return nil
 	}
 }
 
diff --git a/apps/flowlord/sqlite/tasks_test.go b/apps/flowlord/sqlite/tasks_test.go
index 3cee5f7..79a2046 100644
--- a/apps/flowlord/sqlite/tasks_test.go
+++ b/apps/flowlord/sqlite/tasks_test.go
@@ -6,6 +6,7 @@ import (
 
 	"github.com/hydronica/trial"
 	"github.com/pcelvng/task"
+	"github.com/pcelvng/task/bus/nop"
 )
 
 func TestGetTasksByDate(t *testing.T) {
@@ -220,6 +221,79 @@ func TestAddStoresRunningForEmptyResult(t *testing.T) {
 	}
 }
 
+func TestSendFunc(t *testing.T) {
+	db := &SQLite{LocalPath: ":memory:"}
+	if err := db.initDB(); err != nil {
+		t.Fatalf("initDB: %v", err)
+	}
+	defer db.Close()
+
+	created := "2024-01-15T10:00:00Z"
+	tsk := task.Task{
+		ID:      "send-1",
+		Type:    "alpha",
+		Job:     "load",
+		Info:    "?date=2024-01-15",
+		Created: created,
+	}
+
+	t.Run("success", func(t *testing.T) {
+		producer, err := nop.NewProducer("")
+		if err != nil {
+			t.Fatal(err)
+		}
+		send := db.SendFunc(producer)
+		if err := send("alpha", &tsk); err != nil {
+			t.Fatalf("SendFunc: %v", err)
+		}
+		if len(producer.Messages["alpha"]) != 1 {
+			t.Fatalf("messages sent = %d, want 1", len(producer.Messages["alpha"]))
+		}
+		got, err := db.GetTaskRecord("alpha", "load", "send-1", created)
+		if err != nil {
+			t.Fatalf("GetTaskRecord: %v", err)
+		}
+		if got.Result != ResultRunning {
+			t.Errorf("result = %q, want %q", got.Result, ResultRunning)
+		}
+	})
+
+	t.Run("producer failure: no running record remains", func(t *testing.T) {
+		failCreated := "2024-01-15T11:00:00Z"
+		failTask := task.Task{
+			ID:      "send-fail",
+			Type:    "alpha",
+			Job:     "load",
+			Info:    "?date=2024-01-15",
+			Created: failCreated,
+		}
+		producer, err := nop.NewProducer("send_err")
+		if err != nil {
+			t.Fatal(err)
+		}
+		send := db.SendFunc(producer)
+		if err := send("alpha", &failTask); err == nil {
+			t.Fatal("expected send error")
+		}
+		got, err := db.GetTaskRecord("alpha", "load", "send-fail", failCreated)
+		if err != nil {
+			t.Fatalf("GetTaskRecord: %v", err)
+		}
+		if got.Result == ResultRunning {
+			t.Errorf("result = %q, want non-running after send failure", got.Result)
+		}
+		if got.Result != task.ErrResult {
+			t.Errorf("result = %q, want %q", got.Result, task.ErrResult)
+		}
+		if got.Msg != "send_err" {
+			t.Errorf("msg = %q, want send_err", got.Msg)
+		}
+		if len(producer.Messages["alpha"]) != 0 {
+			t.Errorf("messages sent = %d, want 0", len(producer.Messages["alpha"]))
+		}
+	})
+}
+
 func TestGetTaskRecord(t *testing.T) {
 	db := &SQLite{LocalPath: ":memory:"}
 	if err := db.initDB(); err != nil {

From 330b47fb28c309bdc32d49e71a3f0b7dc7cacb22 Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Mon, 21 Sep 2026 14:06:46 -0600
Subject: [PATCH 4/6] flowlord: keep cell selected when scrolling

---
 apps/flowlord/handler/static/utils.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/flowlord/handler/static/utils.js b/apps/flowlord/handler/static/utils.js
index b59a9f2..328d860 100644
--- a/apps/flowlord/handler/static/utils.js
+++ b/apps/flowlord/handler/static/utils.js
@@ -348,8 +348,8 @@
         });
 
         document.addEventListener('scroll', function() {
-            if (activeCell) {
-                deactivateCell();
+            if (activeCell && activeActionBar) {
+                positionActionBar(activeActionBar, activeCell);
             }
         }, true);
     }

From b9758ee797a44284148b3d3ba51bea1030301722 Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Wed, 23 Sep 2026 13:32:36 -0600
Subject: [PATCH 5/6] chore(docs): update docs to clarify rerun vs backload
 actions

---
 apps/flowlord/README.md               | 17 ++++++++++++++++-
 apps/flowlord/handler/static/utils.js |  3 +++
 2 files changed, 19 insertions(+), 1 deletion(-)

diff --git a/apps/flowlord/README.md b/apps/flowlord/README.md
index 9dabcab..15fbbd4 100644
--- a/apps/flowlord/README.md
+++ b/apps/flowlord/README.md
@@ -13,7 +13,7 @@
 - **Alerting** - Slack notifications for failed tasks and incomplete jobs with smart frequency management
 - **RESTful API** - Web UI and API for monitoring workflows, viewing task history, and managing alerts
 
-[![Static Badge](https://img.shields.io/badge/API%20Docs-green)](https://github.com/pcelvng/task-tools/wiki/Flowlord-API)
+[![Static Badge](https://img.shields.io/badge/API%20Docs-green)](API.md)
 
 <br clear="all"/>
 
@@ -55,6 +55,21 @@ Built-in web UI for monitoring workflows and troubleshooting. Uses Go templates
 
 Access at `http://localhost:8080/` by default (`status_port = 8080`). Set `status_port = 0` to run headless with orchestration only — the dashboard, backload API, and other HTTP endpoints are disabled.
 
+### Row actions (Tasks vs Workflow)
+
+The tasks and workflow tables both expose a leading action column, but the behavior is different:
+
+| View | Row control | What it does |
+|------|-------------|----------------|
+| **Tasks** (`/web/task`) | Rerun (replay icon) | Opens a confirmation modal, then [`POST /rerun`](API.md#post-rerun) to re-queue **that same task** (same ID and info; retry-related meta is stripped and `rerun=manual` is set). Does **not** open the backload form. |
+| **Workflow** (`/web/workflow`) | Run (play icon) | Navigates to `/web/backload` with query parameters prefilled from the phase row (task type, job, workflow file). Optional `preview=1` triggers a dry-run preview on the backload page. |
+
+Use **backload** when you want to generate tasks from phase rules and templates (single time, date range, or batch). Use **rerun** on the tasks page when you want another attempt of an **existing** task record without leaving the task history view.
+
+**Rerun vs automatic retry:** When a task finishes with `error`, Flowlord may retry it automatically according to the phase `retry` count and `retry_delay` rule—each retry reuses the **same task ID** and info and updates retry metadata (`retry`, `delayed`, etc.). A manual rerun does the same ID/info reuse for operators but clears automatic retry fields, tags `rerun=manual`, and sends immediately without waiting for `retry_delay`. See [POST `/rerun`](API.md#post-rerun) in the API doc.
+
+The shared helper `buildBackloadUrl` in `handler/static/utils.js` is wired on the workflow page only (`enableRowBackloadActions` in `workflow.tmpl`). The tasks page registers `enableRowRerunActions` in `task.js` instead.
+
 | Files View | Tasks View | Alerts View | Workflow View |
 |:----------:|:----------:|:-----------:|:-------------:|
 | [![Files View](../../internal/docs/img/flowlord_files.png)](../../internal/docs/img/flowlord_files.png) | [![Tasks View](../../internal/docs/img/flowlord_tasks.png)](../../internal/docs/img/flowlord_tasks.png) | [![Alerts View](../../internal/docs/img/flowlord_alerts.png)](../../internal/docs/img/flowlord_alerts.png) | [![Workflow View](../../internal/docs/img/flowlord_workflow.png)](../../internal/docs/img/flowlord_workflow.png) |
diff --git a/apps/flowlord/handler/static/utils.js b/apps/flowlord/handler/static/utils.js
index 328d860..36ad166 100644
--- a/apps/flowlord/handler/static/utils.js
+++ b/apps/flowlord/handler/static/utils.js
@@ -211,6 +211,8 @@
         return out;
     }
 
+    // Prefill /web/backload from phase or task-shaped data. Used by workflow row
+    // actions only; the tasks page reruns via POST /rerun and does not navigate here.
     function buildBackloadUrl(taskRow) {
         const params = new URLSearchParams();
         if (taskRow.type) params.set('task', taskRow.type);
@@ -246,6 +248,7 @@
         window.location.href = buildBackloadUrl(rowData);
     }
 
+    // Listens for .row-action-btn clicks (workflow play button). Not used on /web/task.
     function enableRowBackloadActions(root, getRowData) {
         const el = typeof root === 'string' ? document.querySelector(root) : root;
         if (!el || !getRowData) return;

From 091afcc3013a7102dc64f3e3b5f66bc01293b5ce Mon Sep 17 00:00:00 2001
From: Joshua Smith <jbsmith7741@gmail.com>
Date: Wed, 23 Sep 2026 15:05:05 -0600
Subject: [PATCH 6/6] fix flaky test

---
 apps/workers/sql-load/worker.go | 69 +++++++++++++++++++--------------
 1 file changed, 39 insertions(+), 30 deletions(-)

diff --git a/apps/workers/sql-load/worker.go b/apps/workers/sql-load/worker.go
index 02d5468..d19edd9 100644
--- a/apps/workers/sql-load/worker.go
+++ b/apps/workers/sql-load/worker.go
@@ -13,6 +13,7 @@ import (
 	"sort"
 	"strconv"
 	"strings"
+	"sync"
 	"sync/atomic"
 	"time"
 
@@ -339,16 +340,41 @@ func (w *worker) QuerySchema() (err error) {
 // ReadFiles uses a files list and file.Options to read files and process data into a Dataset
 // it will build the cols and rows for each file
 func (ds *TableMeta) ReadFiles(ctx context.Context, files file.Reader, rowChan chan Row, skipErrors bool) {
-	errChan := make(chan error, 2)
+	errChan := make(chan error, 256)
 	dataIn := make(chan []byte, 20)
 	var header []string
 	var hBytes []byte
-	var activeThreads int32
+	var wg sync.WaitGroup
+
+	handleReadErr := func(err error) {
+		if err == nil {
+			return
+		}
+		if skipErrors {
+			ds.skipCount++
+		} else if ds.err == nil {
+			ds.err = err
+		}
+	}
+
+	drainReadErrs := func() {
+		for {
+			select {
+			case err := <-errChan:
+				if skipErrors {
+					log.Println(err)
+				}
+				handleReadErr(err)
+			default:
+				return
+			}
+		}
+	}
 
 	for i := 0; i < 20; i++ {
-		activeThreads++
+		wg.Add(1)
 		go func() { // process row function
-			defer func() { atomic.AddInt32(&activeThreads, -1) }()
+			defer wg.Done()
 			for b := range dataIn {
 				if ds.csv { // csv data parsing
 					if bytes.Equal(b, hBytes) {
@@ -365,7 +391,7 @@ func (ds *TableMeta) ReadFiles(ctx context.Context, files file.Reader, rowChan c
 					var j JsonData
 					if e := json.Unmarshal(b, &j); e != nil {
 						errChan <- fmt.Errorf("json unmarshal error %w %q", e, string(b))
-						return
+						continue
 					}
 
 					if row, err := MakeRow(ds.dbSchema, j); err != nil {
@@ -401,17 +427,13 @@ loop:
 		select {
 		case <-ctx.Done():
 			break loop
-		case err := <-errChan:
-			if skipErrors {
-				ds.skipCount++
-				//log.Println(err)
-			} else {
-				//log.Println(err)
-				ds.err = err
-				break loop
-			}
 		default:
-			dataIn <- scanner.Bytes()
+		}
+
+		dataIn <- scanner.Bytes()
+		drainReadErrs()
+		if ds.err != nil && !skipErrors {
+			break loop
 		}
 	}
 	if scanner.Err() != nil {
@@ -423,21 +445,8 @@ loop:
 	log.Printf("processed %d files at %s, size %s", sts.Files, sts.Path, b.String())
 
 	close(dataIn)
-	for {
-		select {
-		case e := <-errChan:
-			if skipErrors {
-				log.Println(e)
-				ds.skipCount++
-			} else {
-				ds.err = e
-			}
-		default:
-		}
-		if i := atomic.LoadInt32(&activeThreads); i == 0 {
-			break
-		}
-	}
+	wg.Wait()
+	drainReadErrs()
 	close(rowChan)
 	close(errChan)
 }