From 449c83b94a9bfc5a9910ee970f882e92c5ba49bf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Mon, 1 Aug 2022 14:29:00 +0200 Subject: [PATCH] Manager: broadcast worker update after assigning task The Manager now broadcasts a worker update to SocketIO clients when a worker gets a new task assigned. This ensures the "current task" shown in the worker details view is up to date. --- internal/manager/api_impl/workers.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/internal/manager/api_impl/workers.go b/internal/manager/api_impl/workers.go index f2019c8a..3bcf5062 100644 --- a/internal/manager/api_impl/workers.go +++ b/internal/manager/api_impl/workers.go @@ -340,6 +340,10 @@ func (f *Flamenco) ScheduleTask(e echo.Context) error { return sendAPIError(e, http.StatusInternalServerError, "internal error updating task for timeout calculation: %v", err) } + // Broadcast a worker update so that the web frontend will show the newly assigned task. + update := webupdates.NewWorkerUpdate(worker) + f.broadcaster.BroadcastWorkerUpdate(update) + // Convert database objects to API objects: apiCommands := []api.Command{} for _, cmd := range dbTask.Commands {