feat(HAI-001): wire status updates in scheduler (blocked/queued)
This commit is contained in:
@@ -69,8 +69,6 @@ export class Scheduler {
|
||||
let started = 0;
|
||||
|
||||
for (const taskId of ordered) {
|
||||
if (started >= available) break;
|
||||
|
||||
const task = tasks.find((t) => t.id === taskId)!;
|
||||
|
||||
// Check all deps are satisfied (done or in-review)
|
||||
@@ -80,10 +78,17 @@ export class Scheduler {
|
||||
});
|
||||
|
||||
if (unmetDeps.length > 0) {
|
||||
await this.store.setStatus(task.id, "blocked");
|
||||
this.options.onBlocked?.(task, unmetDeps);
|
||||
continue;
|
||||
}
|
||||
|
||||
// Dependencies met — check concurrency
|
||||
if (started >= available) {
|
||||
await this.store.setStatus(task.id, "queued");
|
||||
continue;
|
||||
}
|
||||
|
||||
// Dependencies met — move to in-progress
|
||||
console.log(
|
||||
`[scheduler] Starting ${task.id}: ${task.title} (deps satisfied)`,
|
||||
|
||||
Reference in New Issue
Block a user