releases/ClaudeDo
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 3 Wiki Activity

fix(worker): emit RunCreated after run row exists

Browse Source 
Remove premature RunCreated broadcast from WorkerHub.RunNow and the
duplicate calls in RunAsync retry block and ContinueAsync. RunOnceAsync
now owns the broadcast for every run, fired immediately after the row
insert so the UI never receives an event for a non-existent row.
This commit is contained in:
mika kuns
2026-04-17 14:17:00 +02:00
parent 3423919655
commit 4fb6ba6be8
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/ClaudeDo.Worker/Hub/WorkerHub.cs
View File

@@ -37,7 +37,6 @@ public sealed class WorkerHub : Microsoft.AspNetCore.SignalR.Hub
try try
{ {
await _queue.RunNow(taskId); await _queue.RunNow(taskId);
await _broadcaster.RunCreated(taskId, 1, false);
} }
catch (InvalidOperationException) catch (InvalidOperationException)
{ {

4
src/ClaudeDo.Worker/Runner/TaskRunner.cs
View File

@@ -125,7 +125,6 @@ public sealed class TaskRunner
var retryConfig = resolvedConfig with { ResumeSessionId = result.SessionId }; var retryConfig = resolvedConfig with { ResumeSessionId = result.SessionId };
var retryPrompt = $"The previous attempt failed with:\n\n{result.ErrorMarkdown}\n\nTry again and fix the issues."; var retryPrompt = $"The previous attempt failed with:\n\n{result.ErrorMarkdown}\n\nTry again and fix the issues.";
await _broadcaster.RunCreated(task.Id, 2, true);
var retryResult = await RunOnceAsync(task.Id, slot, runDir, retryConfig, 2, true, retryPrompt, ct); var retryResult = await RunOnceAsync(task.Id, slot, runDir, retryConfig, 2, true, retryPrompt, ct);
if (retryResult.IsSuccess) if (retryResult.IsSuccess)
@@ -216,7 +215,6 @@ public sealed class TaskRunner
await _broadcaster.TaskStarted(slot, taskId, now); await _broadcaster.TaskStarted(slot, taskId, now);
var nextRunNumber = lastRun.RunNumber + 1; var nextRunNumber = lastRun.RunNumber + 1;
await _broadcaster.RunCreated(taskId, nextRunNumber, false);
var result = await RunOnceAsync(taskId, slot, runDir, resolvedConfig, nextRunNumber, false, followUpPrompt, ct); var result = await RunOnceAsync(taskId, slot, runDir, resolvedConfig, nextRunNumber, false, followUpPrompt, ct);
if (result.IsSuccess) if (result.IsSuccess)
@@ -255,6 +253,8 @@ public sealed class TaskRunner
await runRepo.AddAsync(run, ct); await runRepo.AddAsync(run, ct);
} }
await _broadcaster.RunCreated(taskId, runNumber, isRetry);
var arguments = _argsBuilder.Build(config); var arguments = _argsBuilder.Build(config);
await using var logWriter = new LogWriter(logPath); await using var logWriter = new LogWriter(logPath);