in awsiotjobs/mender/mender.go [185:206]
func Process(jobExecution awsiotjobs.JobExecutioner) {
job, err := parseJobDocument(jobExecution)
if err != nil {
jobError, ok := err.(awsiotjobs.JobError)
if ok {
switch jobError.ErrCode {
case "ERR_MENDER_MISSING_URL":
case "ERR_JOB_INVALID_OPERATION":
fmt.Printf("Invalid job document - Rejecting\n")
job.reject(err.(awsiotjobs.JobError))
default:
fmt.Printf("Unknown - Ignoring")
}
} else {
fmt.Printf("Unknown error %s - Ignoring\n", err.Error())
}
} else {
go func() {
job.exec(&mendercmd.MenderCommand{}, timeout)
}()
}
}