Function TerminateJobManager

pkg/jobcontroller/jobcontroller.go:932–938

(ctx context.Context, jobId string)

}

func TerminateJobManager(ctx context.Context, jobId string) error {
	_, err, _ := terminateJobManagerGroup.Do(jobId, func() (any, error) {
		err := doTerminateJobManager(ctx, jobId)
		return nil, err
	})
	return err
}

func doTerminateJobManager(ctx context.Context, jobId string) error {
	var shouldTerminate bool