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

feat(FN-3977): complete Step 1 — overlap fanout semantics

Browse Source 
Fusion-Task-Id: FN-3977
Fusion-Task-Lineage: c84f2ce0-3726-49b2-ad84-6703edbfecf1
This commit is contained in:
Fusion
2026-05-14 15:33:43 -07:00
committed by gsxdsm
parent 652e820f7d
commit 4380f01516
3 changed files with 77 additions and 143 deletions
Download Patch File Download Diff File Expand all files Collapse all files

144
packages/dashboard/app/hooks/__tests__/useBlockerFanout.test.ts
View File

@@ -40,6 +40,10 @@ describe("computeBlockerFanoutMap", () => {
totalCount: 1,
activeTodoCount: 1,
dependentIds: ["FN-2"],
dependencyDependentIds: ["FN-2"],
overlapBlockedDependentIds: [],
overlapBlockedActiveCount: 0,
overlapBlockedTodoCount: 0,
staleBlockedByDependentIds: [],
isHighFanout: false,
escalation: undefined,
@@ -57,24 +61,10 @@ describe("computeBlockerFanoutMap", () => {
totalCount: 2,
activeTodoCount: 1,
dependentIds: ["FN-2", "FN-3"],
staleBlockedByDependentIds: [],
isHighFanout: false,
escalation: undefined,
});
});
it("excludes done/archived dependents from totalCount but keeps dependentIds", () => {
const tasks = [
createTask("FN-1", "in-progress"),
createTask("FN-2", "done", { dependencies: ["FN-1"] }),
createTask("FN-3", "archived", { blockedBy: "FN-1" }),
createTask("FN-4", "todo", { dependencies: ["FN-1"] }),
];
expect(computeBlockerFanoutMap(tasks).get("FN-1")).toEqual({
totalCount: 1,
activeTodoCount: 1,
dependentIds: ["FN-2", "FN-3", "FN-4"],
dependencyDependentIds: ["FN-2"],
overlapBlockedDependentIds: ["FN-3"],
overlapBlockedActiveCount: 1,
overlapBlockedTodoCount: 0,
staleBlockedByDependentIds: [],
isHighFanout: false,
escalation: undefined,
@@ -87,107 +77,47 @@ describe("computeBlockerFanoutMap", () => {
createTask("FN-3", "todo", { blockedBy: "MISSING" }),
];
expect(computeBlockerFanoutMap(tasks).get("MISSING")).toEqual({
totalCount: 2,
activeTodoCount: 2,
dependentIds: ["FN-2", "FN-3"],
staleBlockedByDependentIds: ["FN-3"],
isHighFanout: false,
escalation: undefined,
});
expect(computeBlockerFanoutMap(tasks).get("MISSING")?.staleBlockedByDependentIds).toEqual(["FN-3"]);
});
it("marks blockedBy edges stale when blocker is done", () => {
const tasks = [createTask("B", "done"), createTask("D", "todo", { blockedBy: "B" })];
expect(computeBlockerFanoutMap(tasks).get("B")?.staleBlockedByDependentIds).toEqual(["D"]);
});
it("marks blockedBy edges stale when blocker is archived", () => {
const tasks = [createTask("B", "archived"), createTask("D", "todo", { blockedBy: "B" })];
expect(computeBlockerFanoutMap(tasks).get("B")?.staleBlockedByDependentIds).toEqual(["D"]);
});
it("marks blockedBy edges stale when blocker is in-review and paused", () => {
const tasks = [createTask("B", "in-review", { paused: true }), createTask("D", "todo", { blockedBy: "B" })];
expect(computeBlockerFanoutMap(tasks).get("B")?.staleBlockedByDependentIds).toEqual(["D"]);
});
it("marks blockedBy edges stale when blocker failed in-review at max retries", () => {
const tasks = [
createTask("B", "in-review", { status: "failed", mergeRetries: MAX_AUTO_MERGE_RETRIES }),
createTask("D", "todo", { blockedBy: "B" }),
];
expect(computeBlockerFanoutMap(tasks).get("B")?.staleBlockedByDependentIds).toEqual(["D"]);
});
it("FN-3897 regression: reports active and todo downstream counts for high fan-out blockers", () => {
it("flags overlap fan-out blockers with at least 5 blockedBy todo dependents as high fan-out", () => {
const tasks = [
createTask("B", "in-progress"),
createTask("D1", "todo", { dependencies: ["B"] }),
createTask("D2", "todo", { blockedBy: "B" }),
createTask("D3", "in-review", { dependencies: ["B"] }),
createTask("D4", "done", { dependencies: ["B"] }),
];
expect(computeBlockerFanoutMap(tasks).get("B")).toEqual({
totalCount: 3,
activeTodoCount: 2,
dependentIds: ["D1", "D2", "D3", "D4"],
staleBlockedByDependentIds: [],
isHighFanout: false,
escalation: undefined,
});
});
it("flags blockers with at least 5 active todo dependents as high fan-out", () => {
const tasks = [
createTask("B", "in-progress"),
createTask("D1", "todo", { dependencies: ["B"] }),
createTask("D2", "todo", { dependencies: ["B"] }),
createTask("D3", "todo", { blockedBy: "B" }),
createTask("D4", "todo", { blockedBy: "B" }),
createTask("D5", "todo", { dependencies: ["B"] }),
createTask("DONE", "done", { dependencies: ["B"] }),
createTask("D5", "todo", { blockedBy: "B" }),
createTask("D6", "todo", { blockedBy: "B" }),
];
expect(computeBlockerFanoutMap(tasks).get("B")).toEqual({
totalCount: 5,
activeTodoCount: 5,
dependentIds: ["D1", "D2", "D3", "D4", "D5", "DONE"],
staleBlockedByDependentIds: [],
isHighFanout: true,
escalation: undefined,
});
expect(computeBlockerFanoutMap(tasks).get("B")?.isHighFanout).toBe(true);
});
it("does not flag ordinary fan-out chains below threshold", () => {
it("does not flag dependency-only chains as overlap high fan-out", () => {
const tasks = [
createTask("B", "in-review"),
createTask("B", "in-progress"),
createTask("D1", "todo", { dependencies: ["B"] }),
createTask("D2", "todo", { blockedBy: "B" }),
createTask("D2", "todo", { dependencies: ["B"] }),
createTask("D3", "todo", { dependencies: ["B"] }),
createTask("D4", "todo", { dependencies: ["B"] }),
createTask("ARCH", "archived", { dependencies: ["B"] }),
createTask("D5", "todo", { dependencies: ["B"] }),
];
expect(computeBlockerFanoutMap(tasks).get("B")).toEqual({
totalCount: 4,
activeTodoCount: 4,
dependentIds: ["D1", "D2", "D3", "D4", "ARCH"],
staleBlockedByDependentIds: [],
isHighFanout: false,
escalation: undefined,
});
const entry = computeBlockerFanoutMap(tasks).get("B");
expect(entry?.activeTodoCount).toBe(5);
expect(entry?.overlapBlockedTodoCount).toBe(0);
expect(entry?.isHighFanout).toBe(false);
});
it("escalates aged high fan-out blockers only when old enough", () => {
it("escalates aged overlap high fan-out blockers only when old enough", () => {
const tasks = [
createTask("B", "in-progress", { columnMovedAt: "2026-01-01T00:00:00.000Z" }),
createTask("D1", "todo", { dependencies: ["B"] }),
createTask("D2", "todo", { dependencies: ["B"] }),
createTask("D3", "todo", { dependencies: ["B"] }),
createTask("D4", "todo", { dependencies: ["B"] }),
createTask("D5", "todo", { dependencies: ["B"] }),
createTask("D1", "todo", { blockedBy: "B" }),
createTask("D2", "todo", { blockedBy: "B" }),
createTask("D3", "todo", { blockedBy: "B" }),
createTask("D4", "todo", { blockedBy: "B" }),
createTask("D5", "todo", { blockedBy: "B" }),
];
const entry = computeBlockerFanoutMap(tasks, {
@@ -195,27 +125,7 @@ describe("computeBlockerFanoutMap", () => {
}).get("B");
expect(entry?.isHighFanout).toBe(true);
expect(entry?.escalation?.blockerId).toBe("B");
expect(entry?.escalation?.activeTodoCount).toBe(5);
expect((entry?.escalation?.blockingAgeMs ?? 0) / (60 * 60 * 1000)).toBeGreaterThanOrEqual(1);
});
it("keeps short-lived high fan-out blockers quiet", () => {
const tasks = [
createTask("B", "in-progress", { columnMovedAt: new Date().toISOString() }),
createTask("D1", "todo", { dependencies: ["B"] }),
createTask("D2", "todo", { dependencies: ["B"] }),
createTask("D3", "todo", { dependencies: ["B"] }),
createTask("D4", "todo", { dependencies: ["B"] }),
createTask("D5", "todo", { dependencies: ["B"] }),
];
const entry = computeBlockerFanoutMap(tasks, {
staleHighFanoutAgeThresholdMs: 60 * 60 * 1000,
}).get("B");
expect(entry?.isHighFanout).toBe(true);
expect(entry?.escalation).toBeUndefined();
});
it("keeps MAX_AUTO_MERGE_RETRIES aligned with engine self-healing source", () => {