Function TerminateAndDetachJob

pkg/jobcontroller/jobcontroller.go:921–930

(ctx context.Context, jobId string)

}

func TerminateAndDetachJob(ctx context.Context, jobId string) {
	err := TerminateJobManager(ctx, jobId)
	if err != nil {
		log.Printf("[job:%s] error terminating job manager: %v", jobId, err)
	}
	err = DetachJobFromBlock(ctx, jobId, true)
	if err != nil {
		log.Printf("[job:%s] error detaching job from block: %v", jobId, err)
	}
}

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