blender/flamenco
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert "Manager: broadcast job/task updates in a separate goroutine"

Browse Source 
This reverts commit cd28ef552e2476dda68ba671436b805d7b32a655, as it
breaks the unit tests and I don't want to spend the time to fix those.
This commit is contained in:
Sybren A. Stüvel 2022-05-06 14:48:10 +02:00
parent 98da20f1a9
commit d008991bf4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/manager/task_state_machine/task_state_machine.go
View File

@ -109,7 +109,7 @@ func (sm *StateMachine) taskStatusChangeOnly(
// Broadcast this change to the SocketIO clients. // Broadcast this change to the SocketIO clients.
taskUpdate := webupdates.NewTaskUpdate(task) taskUpdate := webupdates.NewTaskUpdate(task)
taskUpdate.PreviousStatus = &oldTaskStatus taskUpdate.PreviousStatus = &oldTaskStatus
go sm.broadcaster.BroadcastTaskUpdate(taskUpdate) sm.broadcaster.BroadcastTaskUpdate(taskUpdate)
return nil return nil
} }
@ -281,7 +281,7 @@ func (sm *StateMachine) JobStatusChange(
// Broadcast this change to the SocketIO clients. // Broadcast this change to the SocketIO clients.
jobUpdate := webupdates.NewJobUpdate(job) jobUpdate := webupdates.NewJobUpdate(job)
jobUpdate.PreviousStatus = &oldJobStatus jobUpdate.PreviousStatus = &oldJobStatus
go sm.broadcaster.BroadcastJobUpdate(jobUpdate) sm.broadcaster.BroadcastJobUpdate(jobUpdate)
} }
return nil return nil