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

Manager: broadcast job/task updates in a separate goroutine

Browse Source
This commit is contained in:
Sybren A. Stüvel 2022-05-06 12:27:10 +02:00
parent cfab4f5b76
commit cd28ef552e
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
sm.broadcaster.BroadcastTaskUpdate(taskUpdate) go 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
sm.broadcaster.BroadcastJobUpdate(jobUpdate) go sm.broadcaster.BroadcastJobUpdate(jobUpdate)
} }
return nil return nil