func()

in awsiotjobs/awsiotjobs.go [241:255]


func (je *JobExecution) Fail(err JobError) error {
	log.Printf("JOB FAIL: %v\n", err)
	je.mux.Lock()
	je.StatusDetails = map[string]interface{}{
		"error": err.Error(),
	}
	je.Status = "FAILED"
	je.mux.Unlock()
	e := je.sendUpdate()
	if e != nil {
		return err
	}
	je.unsubscribeFromUpdates()
	return nil
}