diff --git a/internal/manager/task_state_machine/task_state_machine.go b/internal/manager/task_state_machine/task_state_machine.go
index b4c964ce..f596be81 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
-	go sm.broadcaster.BroadcastTaskUpdate(taskUpdate)
+	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
-		go sm.broadcaster.BroadcastJobUpdate(jobUpdate)
+		sm.broadcaster.BroadcastJobUpdate(jobUpdate)
 	}
 
 	return nil