root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(HAI-009): complete Step 1 — move queued tasks to Up Next group only

Browse Source
This commit is contained in:
Dustin Byrne
2026-03-25 20:55:06 -04:00
parent f6dc070bd8
commit a205674c1a
1 changed files with 15 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
packages/dashboard/app/utils/worktreeGrouping.ts
View File

@@ -47,8 +47,13 @@ function resolveDependencyOrder(tasks: Task[]): string[] {
} }
/** /**
* Group in-progress tasks by worktree and distribute queued todo tasks * Group in-progress tasks by worktree and collect queued todo tasks
* as visual previews across the worktree groups. * as visual previews in the "Up Next" group.
*
* Queued tasks (eligible "todo" tasks whose dependencies are all satisfied)
* are always placed in the "Up Next" group — they are never distributed
* to worktree-specific groups since they have no worktree assignment yet.
* The number of queued tasks shown is capped at `maxConcurrent`.
*/ */
export function groupByWorktree( export function groupByWorktree(
inProgressTasks: Task[], inProgressTasks: Task[],
@@ -105,26 +110,14 @@ export function groupByWorktree(
}); });
} }
// Distribute queued tasks round-robin across active worktree groups (one per group) // All eligible queued tasks go into the "Up Next" group (capped at maxConcurrent)
const activeGroups = groups.filter((g) => g.label !== "Unassigned"); const queued = orderedEligible.slice(0, maxConcurrent);
let queueIdx = 0; if (queued.length > 0) {
groups.push({
if (activeGroups.length > 0 && orderedEligible.length > 0) { label: "Up Next",
for (let i = 0; i < activeGroups.length && queueIdx < orderedEligible.length; i++) { activeTasks: [],
activeGroups[i].queuedTasks.push(orderedEligible[queueIdx++]); queuedTasks: queued,
} });
}
// Remaining queued tasks go into "Up Next" overflow group
if (queueIdx < orderedEligible.length) {
const remaining = orderedEligible.slice(queueIdx, queueIdx + maxConcurrent);
if (remaining.length > 0) {
groups.push({
label: "Up Next",
activeTasks: [],
queuedTasks: remaining,
});
}
} }
return groups; return groups;