func Process()

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)
		}()
	}
}