1 files changed, 12 insertions, 1 deletions
diff --git a/internal/api/server.go b/internal/api/server.go
index fc9bd63..38108de 100644
--- a/internal/api/server.go
+++ b/internal/api/server.go
@@ -161,8 +161,19 @@ func (s *Server) routes() {
 	s.mux.Handle("GET /", http.FileServerFS(webui.Files))
 }
 
-// forwardResults listens on the executor pool's result channel and broadcasts via WebSocket.
+// forwardResults listens on the executor pool's result and started channels and broadcasts via WebSocket.
 func (s *Server) forwardResults() {
+	go func() {
+		for taskID := range s.pool.Started() {
+			event := map[string]interface{}{
+				"type":      "task_started",
+				"task_id":   taskID,
+				"timestamp": time.Now().UTC(),
+			}
+			data, _ := json.Marshal(event)
+			s.hub.Broadcast(data)
+		}
+	}()
 	for result := range s.pool.Results() {
 		s.processResult(result)
 	}