in awsiotjobs/awsiotjobs.go [264:278]
func (je *JobExecution) Reject(err JobError) error {
log.Printf("JOB REJECTED: %v\n", err)
je.mux.Lock()
je.StatusDetails = map[string]interface{}{
"error": err.Error(),
}
je.Status = "REJECTED"
je.mux.Unlock()
e := je.sendUpdate()
if e != nil {
return err
}
je.unsubscribeFromUpdates()
return nil
}