Merge claudedo/da69bd1770ff4bc9930582a717f1b3c9
This commit is contained in:
@@ -129,6 +129,14 @@ public sealed class TaskRunner
|
||||
return;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
// Queue-claimed dispatches skip StartRunningAsync (the atomic SQL claim in
|
||||
// QueuePicker already flipped the row to Running), so it never broadcasts
|
||||
// TaskUpdated for this transition. Send it here so the task-list badge flips
|
||||
// live instead of staying on "Queued" until the run finishes.
|
||||
await _broadcaster.TaskUpdated(task.Id);
|
||||
}
|
||||
await _broadcaster.TaskStarted(slot, task.Id, now);
|
||||
|
||||
await _skillSeeder.SeedAsync(runDir, resolvedConfig.SkillNames, wtCtx is not null, ct);
|
||||
@@ -251,7 +259,14 @@ public sealed class TaskRunner
|
||||
return;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
// Queue-claimed dispatches skip StartRunningAsync, so broadcast TaskUpdated here
|
||||
// (see RunAsync for the full rationale).
|
||||
await _broadcaster.TaskUpdated(taskId);
|
||||
}
|
||||
await _broadcaster.TaskStarted(slot, taskId, now);
|
||||
await _broadcaster.TaskUpdated(taskId);
|
||||
|
||||
await _skillSeeder.SeedAsync(runDir, resolvedConfig.SkillNames, wtCtx is not null, ct);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user