Function doTerminateJobManager

pkg/jobcontroller/jobcontroller.go:940–962

(ctx context.Context, jobId string)

}

func doTerminateJobManager(ctx context.Context, jobId string) error {
	var shouldTerminate bool
	var job *waveobj.Job
	err := wstore.DBUpdateFn(ctx, jobId, func(j *waveobj.Job) {
		job = j
		if j.JobManagerStatus == JobManagerStatus_Done {
			shouldTerminate = false
			return
		}
		j.TerminateOnReconnect = true
		shouldTerminate = true
	})
	if err != nil {
		return fmt.Errorf("failed to set TerminateOnReconnect: %w", err)
	}

	if !shouldTerminate {
		log.Printf("[job:%s] already terminated, skipping", jobId)
		return nil
	}

	return remoteTerminateJobManager(ctx, job)
}

func DisconnectJob(ctx context.Context, jobId string) error {
	job, err := wstore.DBMustGet[*waveobj.Job](ctx, jobId)