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