chore(worker): drop the unsubscribed RunCreated broadcast

This commit is contained in:
mika kuns
2026-08-07 09:55:21 +02:00
parent 1e383e1c1f
commit 66630d5ce2
3 changed files with 0 additions and 6 deletions
-1
View File
@@ -159,7 +159,6 @@ launch specs · worktrees · agents/settings/lists · reports/notes/prep · diag
- `TaskMessage` - `TaskMessage`
- `WorktreeUpdated` - `WorktreeUpdated`
- `TaskUpdated` - `TaskUpdated`
- `RunCreated`
- `ListUpdated` - `ListUpdated`
- `WorkerLog` - `WorkerLog`
- `PrimeFired` - `PrimeFired`
@@ -40,9 +40,6 @@ public sealed class HubBroadcaster : IPrimeBroadcaster, IRefineBroadcaster
public Task ListUpdated(string listId) => public Task ListUpdated(string listId) =>
_hub.Clients.All.SendAsync("ListUpdated", listId); _hub.Clients.All.SendAsync("ListUpdated", listId);
public Task RunCreated(string taskId, int runNumber, bool isRetry) =>
_hub.Clients.All.SendAsync("RunCreated", taskId, runNumber, isRetry);
public Task UsageUpdated(UsageSnapshotDto snapshot) => public Task UsageUpdated(UsageSnapshotDto snapshot) =>
_hub.Clients.All.SendAsync("UsageUpdated", snapshot); _hub.Clients.All.SendAsync("UsageUpdated", snapshot);
-2
View File
@@ -358,8 +358,6 @@ public sealed class TaskRunner
await taskRepo.SetLogPathAsync(taskId, logPath, ct); await taskRepo.SetLogPathAsync(taskId, logPath, 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);