Function writeJobTerminationMessage

pkg/jobcontroller/jobcontroller.go:1604–1615

(ctx context.Context, jobId string, job *waveobj.Job, msg string)

}

func writeJobTerminationMessage(ctx context.Context, jobId string, job *waveobj.Job, msg string) {
	if job == nil {
		return
	}
	shouldWrite := jobTerminationMessageWritten.TestAndSet(jobId, true, func(val bool, exists bool) bool {
		return !exists || !val
	})
	if shouldWrite {
		resetTerminalState(ctx, job.AttachedBlockId)
		writeMutedMessageToTerminal(job.AttachedBlockId, msg)
	}
}