in awsiotjobs/awsiotjobs.go [220:232]
func (je *JobExecution) Success(statusDetails StatusDetails) error {
log.Printf("JOB SUCCEEDED: %v\n", statusDetails)
je.mux.Lock()
je.StatusDetails = statusDetails
je.Status = "SUCCEEDED"
je.mux.Unlock()
err := je.sendUpdate()
if err != nil {
return err
}
je.unsubscribeFromUpdates()
return nil
}