From cd28ef552e2476dda68ba671436b805d7b32a655 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Fri, 6 May 2022 12:27:10 +0200 Subject: [PATCH] Manager: broadcast job/task updates in a separate goroutine --- internal/manager/task_state_machine/task_state_machine.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/manager/task_state_machine/task_state_machine.go b/internal/manager/task_state_machine/task_state_machine.go index f596be81..b4c964ce 100644 --- a/internal/manager/task_state_machine/task_state_machine.go +++ b/internal/manager/task_state_machine/task_state_machine.go @@ -109,7 +109,7 @@ func (sm *StateMachine) taskStatusChangeOnly( // Broadcast this change to the SocketIO clients. taskUpdate := webupdates.NewTaskUpdate(task) taskUpdate.PreviousStatus = &oldTaskStatus - sm.broadcaster.BroadcastTaskUpdate(taskUpdate) + go sm.broadcaster.BroadcastTaskUpdate(taskUpdate) return nil } @@ -281,7 +281,7 @@ func (sm *StateMachine) JobStatusChange( // Broadcast this change to the SocketIO clients. jobUpdate := webupdates.NewJobUpdate(job) jobUpdate.PreviousStatus = &oldJobStatus - sm.broadcaster.BroadcastJobUpdate(jobUpdate) + go sm.broadcaster.BroadcastJobUpdate(jobUpdate) } return nil